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

Resource Profile Id: 0
Total Time Across All Tasks: 11 s
Locality Level Summary: Process local: 37
Input Size / Records: 264.5 KiB / 37
Shuffle Write Size / Records: 1047.0 KiB / 4389
Associated Job Ids: 4489

digraph G { id="graph_85641"; subgraph graph_stage_85641 { id="graph_stage_85641"; isCluster="true"; label="Stage 85641"; 38463 [id="node_38463" labelType="html" label="SQLExecutionRDD [38463] [Unordered] start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_100800 { id="cluster_100800"; isCluster="true"; label="Exchange"; 38448 [id="node_38448" labelType="html" label="ShuffledRowRDD [38448] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100795 { id="cluster_100795"; isCluster="true"; label="WholeStageCodegen (6)"; 38449 [id="node_38449" labelType="html" label="MapPartitionsRDD [38449] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100794 { id="cluster_100794"; isCluster="true"; label="SortAggregate"; 38450 [id="node_38450" labelType="html" label="MapPartitionsRDD [38450] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100793 { id="cluster_100793"; isCluster="true"; label="InMemoryTableScan"; 38451 [id="node_38451" labelType="html" label="MapPartitionsRDD [38451] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 38452 [id="node_38452" labelType="html" label="SortAggregate(key=[demandChannel#768749, shardId#754568, qty#768769, worklistShardItemId#754569L, demandStream#768750], functions=[first(kpis#768778, false)], output=[shardId#754568, worklistShardItemId#754569L, qty#768769, demandChannel#768749, demandStream#768750, kpis#768911])\n+- *(6) Sort [demandChannel#768749 ASC NULLS FIRST, shardId#754568 ASC NULLS FIRST, qty#768769 ASC NULLS FIRST, worklistShardItemId#754569L ASC NULLS FIRST, demandStream#768750 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#768749, shardId#754568, qty#768769, worklistShardItemId#754569L, demandStream#768750, 37), ENSURE_REQUIREMENTS, [plan_id=1310535]\n +- SortAggregate(key=[demandChannel#768749, shardId#754568, knownfloatingpointnormalized(normalizenanandzero(qty#768769)) AS qty#768769, worklistShardItemId#754569L, demandStream#768750], functions=[partial_first(kpis#768778, false)], output=[demandChannel#768749, shardId#754568, qty#768769, worklistShardItemId#754569L, demandStream#768750, first#76898... [38452] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100887 { id="cluster_100887"; isCluster="true"; label="InMemoryTableScan"; 38459 [id="node_38459" labelType="html" label="MapPartitionsRDD [38459] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 38460 [id="node_38460" labelType="html" label="MapPartitionsRDD [38460] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 38461 [id="node_38461" labelType="html" label="MapPartitionsRDD [38461] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100886 { id="cluster_100886"; isCluster="true"; label="DeserializeToObject"; 38462 [id="node_38462" labelType="html" label="MapPartitionsRDD [38462] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100888 { id="cluster_100888"; isCluster="true"; label="mapPartitions"; 38464 [id="node_38464" labelType="html" label="MapPartitionsRDD [38464] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100908 { id="cluster_100908"; isCluster="true"; label="union"; 38473 [id="node_38473" labelType="html" label="UnionRDD [38473] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100909 { id="cluster_100909"; isCluster="true"; label="filter"; 38474 [id="node_38474" labelType="html" label="MapPartitionsRDD [38474] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_100910 { id="cluster_100910"; isCluster="true"; label="distinct"; 38475 [id="node_38475" labelType="html" label="MapPartitionsRDD [38475] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 38448->38449; 38449->38450; 38450->38451; 38451->38452; 38452->38459; 38459->38460; 38460->38461; 38461->38462; 38462->38463; 38463->38464; 38464->38473; 38473->38474; 38474->38475; }

38447,38448

38452

Event Timeline

Enable zooming