crp-order-quantity-kpi-service - Details for Stage 446450 (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: 154908

digraph G { id="graph_446450"; subgraph graph_stage_446450 { id="graph_stage_446450"; isCluster="true"; label="Stage 446450"; 1243938 [id="node_1243938" labelType="html" label="SQLExecutionRDD [1243938] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3153377 { id="cluster_3153377"; isCluster="true"; label="Exchange"; 1243929 [id="node_1243929" labelType="html" label="ShuffledRowRDD [1243929] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153372 { id="cluster_3153372"; isCluster="true"; label="WholeStageCodegen (5)"; 1243930 [id="node_1243930" labelType="html" label="MapPartitionsRDD [1243930] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153371 { id="cluster_3153371"; isCluster="true"; label="SortAggregate"; 1243931 [id="node_1243931" labelType="html" label="MapPartitionsRDD [1243931] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153370 { id="cluster_3153370"; isCluster="true"; label="InMemoryTableScan"; 1243932 [id="node_1243932" labelType="html" label="MapPartitionsRDD [1243932] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243933 [id="node_1243933" labelType="html" label="SortAggregate(key=[demandChannel#21564021, shardId#21517301, qty#21564041, worklistShardItemId#21517302L, demandStream#21564022], functions=[first(kpis#21564050, false)], output=[shardId#21517301, worklistShardItemId#21517302L, qty#21564041, demandChannel#21564021, demandStream#21564022, kpis#21564163])\n+- *(5) Sort [demandChannel#21564021 ASC NULLS FIRST, shardId#21517301 ASC NULLS FIRST, qty#21564041 ASC NULLS FIRST, worklistShardItemId#21517302L ASC NULLS FIRST, demandStream#21564022 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#21564021, shardId#21517301, qty#21564041, worklistShardItemId#21517302L, demandStream#21564022, 20), ENSURE_REQUIREMENTS, [plan_id=21363224]\n +- SortAggregate(key=[demandChannel#21564021, shardId#21517301, knownfloatingpointnormalized(normalizenanandzero(qty#21564041)) AS qty#21564041, worklistShardItemId#21517302L, demandStream#21564022], functions=[partial_first(kpis#21564050, false)], output=[demandChannel#21564021, shardId#21517301, qty#215640... [1243933] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243934 [id="node_1243934" labelType="html" label="MapPartitionsRDD [1243934] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243935 [id="node_1243935" labelType="html" label="MapPartitionsRDD [1243935] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 1243936 [id="node_1243936" labelType="html" label="MapPartitionsRDD [1243936] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153369 { id="cluster_3153369"; isCluster="true"; label="DeserializeToObject"; 1243937 [id="node_1243937" labelType="html" label="MapPartitionsRDD [1243937] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153418 { id="cluster_3153418"; isCluster="true"; label="mapPartitions"; 1243939 [id="node_1243939" labelType="html" label="MapPartitionsRDD [1243939] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 1243929->1243930; 1243930->1243931; 1243931->1243932; 1243932->1243933; 1243933->1243934; 1243934->1243935; 1243935->1243936; 1243936->1243937; 1243937->1243938; 1243938->1243939; }

1243928,1243929

1243933

Event Timeline

Enable zooming