crp-order-quantity-kpi-service - Details for Stage 445844 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Node local: 20
Shuffle Read Size / Records: 96.3 KiB / 256
Associated Job Ids: 154706

digraph G { id="graph_445844"; subgraph graph_stage_445844 { id="graph_stage_445844"; isCluster="true"; label="Stage 445844"; 1242154 [id="node_1242154" labelType="html" label="SQLExecutionRDD [1242154] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3149028 { id="cluster_3149028"; isCluster="true"; label="Exchange"; 1242145 [id="node_1242145" labelType="html" label="ShuffledRowRDD [1242145] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149022 { id="cluster_3149022"; isCluster="true"; label="WholeStageCodegen (5)"; 1242146 [id="node_1242146" labelType="html" label="MapPartitionsRDD [1242146] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149021 { id="cluster_3149021"; isCluster="true"; label="SortAggregate"; 1242147 [id="node_1242147" labelType="html" label="MapPartitionsRDD [1242147] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149020 { id="cluster_3149020"; isCluster="true"; label="InMemoryTableScan"; 1242148 [id="node_1242148" labelType="html" label="MapPartitionsRDD [1242148] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1242149 [id="node_1242149" labelType="html" label="SortAggregate(key=[demandChannel#21533202, shardId#21517301, qty#21533222, worklistShardItemId#21517302L, demandStream#21533203], functions=[first(kpis#21533231, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21533222, demandChannel#21533202, demandStream#21533203, kpis#21533344])\n+- *(5) Sort [demandChannel#21533202 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21533222 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21533203 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21533202, shardId#21517301, qty#21533222, worklistShardItemId#21517302L, demandStream#21533203, 20), ENSURE_REQUIREMENTS, [plan_id=21351252]\n +- SortAggregate(key=[demandChannel#21533202, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21533222)) AS qty#21533222, worklistShardItemId#21517302L, demandStream#21533203], functions=[partial_first(kpis#21533231, false)], output=[demandChannel#21533202, shardId#21517301, qty#215332... [1242149] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1242150 [id="node_1242150" labelType="html" label="MapPartitionsRDD [1242150] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1242151 [id="node_1242151" labelType="html" label="MapPartitionsRDD [1242151] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1242152 [id="node_1242152" labelType="html" label="MapPartitionsRDD [1242152] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149019 { id="cluster_3149019"; isCluster="true"; label="DeserializeToObject"; 1242153 [id="node_1242153" labelType="html" label="MapPartitionsRDD [1242153] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149068 { id="cluster_3149068"; isCluster="true"; label="mapPartitions"; 1242155 [id="node_1242155" labelType="html" label="MapPartitionsRDD [1242155] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1242145->1242146; 1242146->1242147; 1242147->1242148; 1242148->1242149; 1242149->1242150; 1242150->1242151; 1242151->1242152; 1242152->1242153; 1242153->1242154; 1242154->1242155; }

1242144,1242145

1242149

Event Timeline

Enable zooming