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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 30
Input Size / Records: 8.9 MiB / 90
Shuffle Write Size / Records: 8.7 MiB / 479444
Associated Job Ids: 52605

digraph G { id="graph_190339"; subgraph graph_stage_190339 { id="graph_stage_190339"; isCluster="true"; label="Stage 190339"; subgraph cluster_1107689 { id="cluster_1107689"; isCluster="true"; label="Exchange"; 423783 [id="node_423783" labelType="html" label="ShuffledRowRDD [423783] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107686 { id="cluster_1107686"; isCluster="true"; label="WholeStageCodegen (7)"; 423784 [id="node_423784" labelType="html" label="MapPartitionsRDD [423784] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107685 { id="cluster_1107685"; isCluster="true"; label="SortAggregate"; 423785 [id="node_423785" labelType="html" label="MapPartitionsRDD [423785] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107684 { id="cluster_1107684"; isCluster="true"; label="InMemoryTableScan"; 423786 [id="node_423786" labelType="html" label="MapPartitionsRDD [423786] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423787 [id="node_423787" labelType="html" label="SortAggregate(key=[demandChannel#6835889, shardId#6552521, qty#6835909, worklistShardItemId#6552522L, demandStream#6835890], functions=[first(kpis#6835918, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6835909, demandChannel#6835889, demandStream#6835890, kpis#6836031])\n+- *(7) Sort [demandChannel#6835889 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6835909 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6835890 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6835889, shardId#6552521, qty#6835909, worklistShardItemId#6552522L, demandStream#6835890, 30), ENSURE_REQUIREMENTS, [plan_id=29053926]\n +- SortAggregate(key=[demandChannel#6835889, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6835909)) AS qty#6835909, worklistShardItemId#6552522L, demandStream#6835890], functions=[partial_first(kpis#6835918, false)], output=[demandChannel#6835889, shardId#6552521, qty#6835909, worklistShardItemId#6552522L... [423787] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107796 { id="cluster_1107796"; isCluster="true"; label="InMemoryTableScan"; 423794 [id="node_423794" labelType="html" label="MapPartitionsRDD [423794] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423795 [id="node_423795" labelType="html" label="MapPartitionsRDD [423795] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 423796 [id="node_423796" labelType="html" label="MapPartitionsRDD [423796] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107793 { id="cluster_1107793"; isCluster="true"; label="WholeStageCodegen (1)"; 423797 [id="node_423797" labelType="html" label="MapPartitionsRDD [423797] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1107792 { id="cluster_1107792"; isCluster="true"; label="Exchange"; 423798 [id="node_423798" labelType="html" label="MapPartitionsRDD [423798] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 423783->423784; 423784->423785; 423785->423786; 423786->423787; 423787->423794; 423794->423795; 423795->423796; 423796->423797; 423797->423798; }

423782,423783

423787

Event Timeline

Enable zooming