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

Resource Profile Id: 0
Total Time Across All Tasks: 3 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: 52665

digraph G { id="graph_190630"; subgraph graph_stage_190630 { id="graph_stage_190630"; isCluster="true"; label="Stage 190630"; subgraph cluster_1109612 { id="cluster_1109612"; isCluster="true"; label="Exchange"; 424566 [id="node_424566" labelType="html" label="ShuffledRowRDD [424566] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109609 { id="cluster_1109609"; isCluster="true"; label="WholeStageCodegen (7)"; 424567 [id="node_424567" labelType="html" label="MapPartitionsRDD [424567] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109608 { id="cluster_1109608"; isCluster="true"; label="SortAggregate"; 424568 [id="node_424568" labelType="html" label="MapPartitionsRDD [424568] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109607 { id="cluster_1109607"; isCluster="true"; label="InMemoryTableScan"; 424569 [id="node_424569" labelType="html" label="MapPartitionsRDD [424569] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424570 [id="node_424570" labelType="html" label="SortAggregate(key=[demandChannel#6848123, shardId#6552521, qty#6848143, worklistShardItemId#6552522L, demandStream#6848124], functions=[first(kpis#6848152, false)], output=[shardId#6552521, worklistShardItemId#6552522L, qty#6848143, demandChannel#6848123, demandStream#6848124, kpis#6848265])\n+- *(7) Sort [demandChannel#6848123 ASC NULLS FIRST, shardId#6552521 ASC NULLS FIRST, qty#6848143 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST, demandStream#6848124 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#6848123, shardId#6552521, qty#6848143, worklistShardItemId#6552522L, demandStream#6848124, 30), ENSURE_REQUIREMENTS, [plan_id=29058789]\n +- SortAggregate(key=[demandChannel#6848123, shardId#6552521, knownfloatingpointnormalized(normalizenanandzero(qty#6848143)) AS qty#6848143, worklistShardItemId#6552522L, demandStream#6848124], functions=[partial_first(kpis#6848152, false)], output=[demandChannel#6848123, shardId#6552521, qty#6848143, worklistShardItemId#6552522L... [424570] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109719 { id="cluster_1109719"; isCluster="true"; label="InMemoryTableScan"; 424577 [id="node_424577" labelType="html" label="MapPartitionsRDD [424577] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424578 [id="node_424578" labelType="html" label="MapPartitionsRDD [424578] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424579 [id="node_424579" labelType="html" label="MapPartitionsRDD [424579] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109716 { id="cluster_1109716"; isCluster="true"; label="WholeStageCodegen (1)"; 424580 [id="node_424580" labelType="html" label="MapPartitionsRDD [424580] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109715 { id="cluster_1109715"; isCluster="true"; label="Exchange"; 424581 [id="node_424581" labelType="html" label="MapPartitionsRDD [424581] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 424566->424567; 424567->424568; 424568->424569; 424569->424570; 424570->424577; 424577->424578; 424578->424579; 424579->424580; 424580->424581; }

424565,424566

424570

Event Timeline

Enable zooming