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

Resource Profile Id: 0
Total Time Across All Tasks: 2 s
Locality Level Summary: Process local: 37
Input Size / Records: 255.5 KiB / 37
Shuffle Write Size / Records: 3.3 KiB / 37
Associated Job Ids: 6346

digraph G { id="graph_115496"; subgraph graph_stage_115496 { id="graph_stage_115496"; isCluster="true"; label="Stage 115496"; subgraph cluster_144434 { id="cluster_144434"; isCluster="true"; label="Exchange"; 55537 [id="node_55537" labelType="html" label="ShuffledRowRDD [55537] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144428 { id="cluster_144428"; isCluster="true"; label="WholeStageCodegen (6)"; 55538 [id="node_55538" labelType="html" label="MapPartitionsRDD [55538] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144427 { id="cluster_144427"; isCluster="true"; label="SortAggregate"; 55539 [id="node_55539" labelType="html" label="MapPartitionsRDD [55539] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144426 { id="cluster_144426"; isCluster="true"; label="InMemoryTableScan"; 55540 [id="node_55540" labelType="html" label="MapPartitionsRDD [55540] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55541 [id="node_55541" labelType="html" label="SortAggregate(key=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[first(kpis#1114548, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1114539, demandChannel#1114519, demandStream#1114520, kpis#1114681])\n+- *(6) Sort [demandChannel#1114519 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1114539 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1114520 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L, demandStream#1114520, 37), ENSURE_REQUIREMENTS, [plan_id=1751587]\n +- SortAggregate(key=[demandChannel#1114519, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1114539)) AS qty#1114539, worklistShardItemId#1100458L, demandStream#1114520], functions=[partial_first(kpis#1114548, false)], output=[demandChannel#1114519, shardId#1100457, qty#1114539, worklistShardItemId#1100458L,... [55541] [Cached] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144529 { id="cluster_144529"; isCluster="true"; label="InMemoryTableScan"; 55554 [id="node_55554" labelType="html" label="MapPartitionsRDD [55554] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55555 [id="node_55555" labelType="html" label="MapPartitionsRDD [55555] [Unordered] start at FileStorageAdapterImpl.java:171}"]; 55556 [id="node_55556" labelType="html" label="MapPartitionsRDD [55556] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144526 { id="cluster_144526"; isCluster="true"; label="WholeStageCodegen (1)"; 55557 [id="node_55557" labelType="html" label="MapPartitionsRDD [55557] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144525 { id="cluster_144525"; isCluster="true"; label="Exchange"; 55558 [id="node_55558" labelType="html" label="MapPartitionsRDD [55558] [Unordered] start at FileStorageAdapterImpl.java:171}"]; } } 55537->55538; 55538->55539; 55539->55540; 55540->55541; 55541->55554; 55554->55555; 55555->55556; 55556->55557; 55557->55558; }

55536,55537

55541

Event Timeline

Enable zooming