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

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 30
Input Size / Records: 7.7 MiB / 90
Shuffle Write Size / Records: 7.4 MiB / 410552
Associated Job Ids: 66459

digraph G { id="graph_241411"; subgraph graph_stage_241411 { id="graph_stage_241411"; isCluster="true"; label="Stage 241411"; subgraph cluster_1410827 { id="cluster_1410827"; isCluster="true"; label="Exchange"; 540226 [id="node_540226" labelType="html" label="ShuffledRowRDD [540226] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410824 { id="cluster_1410824"; isCluster="true"; label="WholeStageCodegen (7)"; 540227 [id="node_540227" labelType="html" label="MapPartitionsRDD [540227] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410823 { id="cluster_1410823"; isCluster="true"; label="SortAggregate"; 540228 [id="node_540228" labelType="html" label="MapPartitionsRDD [540228] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410822 { id="cluster_1410822"; isCluster="true"; label="InMemoryTableScan"; 540229 [id="node_540229" labelType="html" label="MapPartitionsRDD [540229] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540230 [id="node_540230" labelType="html" label="SortAggregate(key=[demandChannel#8710381, shardId#8398780, qty#8710401, worklistShardItemId#8398781L, demandStream#8710382], functions=[first(kpis#8710410, false)], output=[shardId#8398780, worklistShardItemId#8398781L, qty#8710401, demandChannel#8710381, demandStream#8710382, kpis#8710523])\n+- *(7) Sort [demandChannel#8710381 ASC NULLS FIRST, shardId#8398780 ASC NULLS FIRST, qty#8710401 ASC NULLS FIRST, worklistShardItemId#8398781L ASC NULLS FIRST, demandStream#8710382 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8710381, shardId#8398780, qty#8710401, worklistShardItemId#8398781L, demandStream#8710382, 30), ENSURE_REQUIREMENTS, [plan_id=36544648]\n +- SortAggregate(key=[demandChannel#8710381, shardId#8398780, knownfloatingpointnormalized(normalizenanandzero(qty#8710401)) AS qty#8710401, worklistShardItemId#8398781L, demandStream#8710382], functions=[partial_first(kpis#8710410, false)], output=[demandChannel#8710381, shardId#8398780, qty#8710401, worklistShardItemId#8398781L... [540230] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410934 { id="cluster_1410934"; isCluster="true"; label="InMemoryTableScan"; 540237 [id="node_540237" labelType="html" label="MapPartitionsRDD [540237] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540238 [id="node_540238" labelType="html" label="MapPartitionsRDD [540238] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 540239 [id="node_540239" labelType="html" label="MapPartitionsRDD [540239] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410931 { id="cluster_1410931"; isCluster="true"; label="WholeStageCodegen (1)"; 540240 [id="node_540240" labelType="html" label="MapPartitionsRDD [540240] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410930 { id="cluster_1410930"; isCluster="true"; label="Exchange"; 540241 [id="node_540241" labelType="html" label="MapPartitionsRDD [540241] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 540226->540227; 540227->540228; 540228->540229; 540229->540230; 540230->540237; 540237->540238; 540238->540239; 540239->540240; 540240->540241; }

540225,540226

540230

Event Timeline

Enable zooming