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

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

digraph G { id="graph_446297"; subgraph graph_stage_446297 { id="graph_stage_446297"; isCluster="true"; label="Stage 446297"; 1243489 [id="node_1243489" labelType="html" label="SQLExecutionRDD [1243489] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3152280 { id="cluster_3152280"; isCluster="true"; label="Exchange"; 1243480 [id="node_1243480" labelType="html" label="ShuffledRowRDD [1243480] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152275 { id="cluster_3152275"; isCluster="true"; label="WholeStageCodegen (5)"; 1243481 [id="node_1243481" labelType="html" label="MapPartitionsRDD [1243481] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152274 { id="cluster_3152274"; isCluster="true"; label="SortAggregate"; 1243482 [id="node_1243482" labelType="html" label="MapPartitionsRDD [1243482] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152273 { id="cluster_3152273"; isCluster="true"; label="InMemoryTableScan"; 1243483 [id="node_1243483" labelType="html" label="MapPartitionsRDD [1243483] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243484 [id="node_1243484" labelType="html" label="SortAggregate(key=[demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[first(kpis#21556307, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21556298, demandChannel#21556278, demandStream#21556279, kpis#21556420])\n+- *(5) Sort [demandChannel#21556278 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21556298 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21556279 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21556278, shardId#21517301, qty#21556298, worklistShardItemId#21517302L, demandStream#21556279, 20), ENSURE_REQUIREMENTS, [plan_id=21360184]\n +- SortAggregate(key=[demandChannel#21556278, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21556298)) AS qty#21556298, worklistShardItemId#21517302L, demandStream#21556279], functions=[partial_first(kpis#21556307, false)], output=[demandChannel#21556278, shardId#21517301, qty#215562... [1243484] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243485 [id="node_1243485" labelType="html" label="MapPartitionsRDD [1243485] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243486 [id="node_1243486" labelType="html" label="MapPartitionsRDD [1243486] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243487 [id="node_1243487" labelType="html" label="MapPartitionsRDD [1243487] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152272 { id="cluster_3152272"; isCluster="true"; label="DeserializeToObject"; 1243488 [id="node_1243488" labelType="html" label="MapPartitionsRDD [1243488] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152321 { id="cluster_3152321"; isCluster="true"; label="mapPartitions"; 1243490 [id="node_1243490" labelType="html" label="MapPartitionsRDD [1243490] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243480->1243481; 1243481->1243482; 1243482->1243483; 1243483->1243484; 1243484->1243485; 1243485->1243486; 1243486->1243487; 1243487->1243488; 1243488->1243489; 1243489->1243490; }

1243479,1243480

1243484

Event Timeline

Enable zooming