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

Resource Profile Id: 0
Total Time Across All Tasks: 0.9 s
Locality Level Summary: Process local: 37
Input Size / Records: 1272.0 B / 1
Shuffle Write Size / Records: 92.0 B / 1
Associated Job Ids: 6537

digraph G { id="graph_119936"; subgraph graph_stage_119936 { id="graph_stage_119936"; isCluster="true"; label="Stage 119936"; subgraph cluster_150035 { id="cluster_150035"; isCluster="true"; label="Exchange"; 57919 [id="node_57919" labelType="html" label="ShuffledRowRDD [57919] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150029 { id="cluster_150029"; isCluster="true"; label="WholeStageCodegen (6)"; 57920 [id="node_57920" labelType="html" label="MapPartitionsRDD [57920] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150028 { id="cluster_150028"; isCluster="true"; label="SortAggregate"; 57921 [id="node_57921" labelType="html" label="MapPartitionsRDD [57921] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150027 { id="cluster_150027"; isCluster="true"; label="InMemoryTableScan"; 57922 [id="node_57922" labelType="html" label="MapPartitionsRDD [57922] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57923 [id="node_57923" labelType="html" label="SortAggregate(key=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[first(kpis#1164592, false)], output=[shardId#1100457, worklistShardItemId#1100458L, qty#1164583, demandChannel#1164563, demandStream#1164564, kpis#1164725])\n+- *(6) Sort [demandChannel#1164563 ASC NULLS FIRST, shardId#1100457 ASC NULLS FIRST, qty#1164583 ASC NULLS FIRST, worklistShardItemId#1100458L ASC NULLS FIRST, demandStream#1164564 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L, demandStream#1164564, 37), ENSURE_REQUIREMENTS, [plan_id=1765755]\n +- SortAggregate(key=[demandChannel#1164563, shardId#1100457, knownfloatingpointnormalized(normalizenanandzero(qty#1164583)) AS qty#1164583, worklistShardItemId#1100458L, demandStream#1164564], functions=[partial_first(kpis#1164592, false)], output=[demandChannel#1164563, shardId#1100457, qty#1164583, worklistShardItemId#1100458L,... [57923] [Cached] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150130 { id="cluster_150130"; isCluster="true"; label="InMemoryTableScan"; 57936 [id="node_57936" labelType="html" label="MapPartitionsRDD [57936] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57937 [id="node_57937" labelType="html" label="MapPartitionsRDD [57937] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; 57938 [id="node_57938" labelType="html" label="MapPartitionsRDD [57938] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150127 { id="cluster_150127"; isCluster="true"; label="WholeStageCodegen (1)"; 57939 [id="node_57939" labelType="html" label="MapPartitionsRDD [57939] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150126 { id="cluster_150126"; isCluster="true"; label="Exchange"; 57940 [id="node_57940" labelType="html" label="MapPartitionsRDD [57940] [Indeterminate] start at FileStorageAdapterImpl.java:171}"]; } } 57919->57920; 57920->57921; 57921->57922; 57922->57923; 57923->57936; 57936->57937; 57937->57938; 57938->57939; 57939->57940; }

57918,57919

57923

57919

57920

57921

57922

57923

57936

57937

57938

57939

57940

Event Timeline

Enable zooming