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

Resource Profile Id: 0
Total Time Across All Tasks: 1 s
Locality Level Summary: Process local: 37
Input Size / Records: 5.8 KiB / 10
Shuffle Write Size / Records: 920.0 B / 10
Associated Job Ids: 6516

digraph G { id="graph_119045"; subgraph graph_stage_119045 { id="graph_stage_119045"; isCluster="true"; label="Stage 119045"; subgraph cluster_149413 { id="cluster_149413"; isCluster="true"; label="Exchange"; 57655 [id="node_57655" labelType="html" label="ShuffledRowRDD [57655] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149408 { id="cluster_149408"; isCluster="true"; label="WholeStageCodegen (6)"; 57656 [id="node_57656" labelType="html" label="MapPartitionsRDD [57656] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149407 { id="cluster_149407"; isCluster="true"; label="SortAggregate"; 57657 [id="node_57657" labelType="html" label="MapPartitionsRDD [57657] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149406 { id="cluster_149406"; isCluster="true"; label="InMemoryTableScan"; 57658 [id="node_57658" labelType="html" label="MapPartitionsRDD [57658] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57659 [id="node_57659" labelType="html" label="SortAggregate(key=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[first(kpis#1159034, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1159025, demandChannel#1159005, demandStream#1159006, kpis#1159167])\n+- *(6) Sort [demandChannel#1159005 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1159025 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1159006 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L, demandStream#1159006, 37), ENSURE_REQUIREMENTS, [plan_id=1764206]\n +- SortAggregate(key=[demandChannel#1159005, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1159025)) AS qty#1159025, worklistShardItemId#1100458L, demandStream#1159006], functions=[partial_first(kpis#1159034, false)], output=[demandChannel#1159005, shardId#1100457, qty#1159025, worklistShardItemId#1100458L,... [57659] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149509 { id="cluster_149509"; isCluster="true"; label="InMemoryTableScan"; 57672 [id="node_57672" labelType="html" label="MapPartitionsRDD [57672] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57673 [id="node_57673" labelType="html" label="MapPartitionsRDD [57673] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57674 [id="node_57674" labelType="html" label="MapPartitionsRDD [57674] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149506 { id="cluster_149506"; isCluster="true"; label="WholeStageCodegen (1)"; 57675 [id="node_57675" labelType="html" label="MapPartitionsRDD [57675] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_149505 { id="cluster_149505"; isCluster="true"; label="Exchange"; 57676 [id="node_57676" labelType="html" label="MapPartitionsRDD [57676] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 57655->57656; 57656->57657; 57657->57658; 57658->57659; 57659->57672; 57672->57673; 57673->57674; 57674->57675; 57675->57676; }

57654,57655

57659

57655

57656

57657

57658

57659

57672

57673

57674

57675

57676

Event Timeline

Enable zooming