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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 30
Input Size / Records: 8.8 MiB / 90
Shuffle Write Size / Records: 8.6 MiB / 475632
Associated Job Ids: 52755

digraph G { id="graph_191042"; subgraph graph_stage_191042 { id="graph_stage_191042"; isCluster="true"; label="Stage 191042"; subgraph cluster_1112324 { id="cluster_1112324"; isCluster="true"; label="Exchange"; 425677 [id="node_425677" labelType="html" label="ShuffledRowRDD [425677] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112321 { id="cluster_1112321"; isCluster="true"; label="WholeStageCodegen (7)"; 425678 [id="node_425678" labelType="html" label="MapPartitionsRDD [425678] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112320 { id="cluster_1112320"; isCluster="true"; label="SortAggregate"; 425679 [id="node_425679" labelType="html" label="MapPartitionsRDD [425679] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112319 { id="cluster_1112319"; isCluster="true"; label="InMemoryTableScan"; 425680 [id="node_425680" labelType="html" label="MapPartitionsRDD [425680] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425681 [id="node_425681" labelType="html" label="SortAggregate(key=[demandChannel#6865298, shardId#6552521, qty#6865318, worklistShardItemId#6552522L, demandStream#6865299], functions=[first(kpis#6865327, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6865318, demandChannel#6865298, demandStream#6865299, kpis#6865440])\n+- *(7) Sort [demandChannel#6865298 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6865318 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6865299 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6865298, shardId#6552521, qty#6865318, worklistShardItemId#6552522L, demandStream#6865299, 30), ENSURE_REQUIREMENTS, [plan_id=29065545]\n +- SortAggregate(key=[demandChannel#6865298, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6865318)) AS qty#6865318, worklistShardItemId#6552522L, demandStream#6865299], functions=[partial_first(kpis#6865327, false)], output=[demandChannel#6865298, shardId#6552521, qty#6865318, worklistShardItemId#6552522L... [425681] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112519 { id="cluster_1112519"; isCluster="true"; label="InMemoryTableScan"; 425726 [id="node_425726" labelType="html" label="MapPartitionsRDD [425726] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425727 [id="node_425727" labelType="html" label="MapPartitionsRDD [425727] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425728 [id="node_425728" labelType="html" label="MapPartitionsRDD [425728] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112516 { id="cluster_1112516"; isCluster="true"; label="WholeStageCodegen (1)"; 425729 [id="node_425729" labelType="html" label="MapPartitionsRDD [425729] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1112515 { id="cluster_1112515"; isCluster="true"; label="Exchange"; 425730 [id="node_425730" labelType="html" label="MapPartitionsRDD [425730] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425677->425678; 425678->425679; 425679->425680; 425680->425681; 425681->425726; 425726->425727; 425727->425728; 425728->425729; 425729->425730; }

425676,425677

425681

Event Timeline

Enable zooming