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

Resource Profile Id: 0
Total Time Across All Tasks: 1.0 s
Locality Level Summary: Process local: 37
Input Size / Records: 14.0 KiB / 25
Shuffle Write Size / Records: 2.2 KiB / 25
Associated Job Ids: 6495

digraph G { id="graph_118315"; subgraph graph_stage_118315 { id="graph_stage_118315"; isCluster="true"; label="Stage 118315"; subgraph cluster_148792 { id="cluster_148792"; isCluster="true"; label="Exchange"; 57391 [id="node_57391" labelType="html" label="ShuffledRowRDD [57391] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148787 { id="cluster_148787"; isCluster="true"; label="WholeStageCodegen (6)"; 57392 [id="node_57392" labelType="html" label="MapPartitionsRDD [57392] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148786 { id="cluster_148786"; isCluster="true"; label="SortAggregate"; 57393 [id="node_57393" labelType="html" label="MapPartitionsRDD [57393] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148785 { id="cluster_148785"; isCluster="true"; label="InMemoryTableScan"; 57394 [id="node_57394" labelType="html" label="MapPartitionsRDD [57394] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57395 [id="node_57395" labelType="html" label="SortAggregate(key=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[first(kpis#1153476, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1153467, demandChannel#1153447, demandStream#1153448, kpis#1153609])\n+- *(6) Sort [demandChannel#1153447 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1153467 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1153448 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L, demandStream#1153448, 37), ENSURE_REQUIREMENTS, [plan_id=1762616]\n +- SortAggregate(key=[demandChannel#1153447, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1153467)) AS qty#1153467, worklistShardItemId#1100458L, demandStream#1153448], functions=[partial_first(kpis#1153476, false)], output=[demandChannel#1153447, shardId#1100457, qty#1153467, worklistShardItemId#1100458L,... [57395] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148888 { id="cluster_148888"; isCluster="true"; label="InMemoryTableScan"; 57408 [id="node_57408" labelType="html" label="MapPartitionsRDD [57408] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57409 [id="node_57409" labelType="html" label="MapPartitionsRDD [57409] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57410 [id="node_57410" labelType="html" label="MapPartitionsRDD [57410] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148885 { id="cluster_148885"; isCluster="true"; label="WholeStageCodegen (1)"; 57411 [id="node_57411" labelType="html" label="MapPartitionsRDD [57411] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_148884 { id="cluster_148884"; isCluster="true"; label="Exchange"; 57412 [id="node_57412" labelType="html" label="MapPartitionsRDD [57412] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 57391->57392; 57392->57393; 57393->57394; 57394->57395; 57395->57408; 57408->57409; 57409->57410; 57410->57411; 57411->57412; }

57390,57391

57395

57391

57392

57393

57394

57395

57408

57409

57410

57411

57412

Event Timeline

Enable zooming