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

Resource Profile Id: 0
Total Time Across All Tasks: 14 s
Locality Level Summary: Node local: 30
Shuffle Read Size / Records: 3.6 MiB / 199840
Shuffle Write Size / Records: 1860.0 B / 30
Associated Job Ids: 52769

digraph G { id="graph_191124"; subgraph graph_stage_191124 { id="graph_stage_191124"; isCluster="true"; label="Stage 191124"; subgraph cluster_1113031 { id="cluster_1113031"; isCluster="true"; label="Exchange"; 425929 [id="node_425929" labelType="html" label="ShuffledRowRDD [425929] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113028 { id="cluster_1113028"; isCluster="true"; label="WholeStageCodegen (2)"; 425930 [id="node_425930" labelType="html" label="MapPartitionsRDD [425930] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113041 { id="cluster_1113041"; isCluster="true"; label="Exchange"; 425936 [id="node_425936" labelType="html" label="ShuffledRowRDD [425936] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113037 { id="cluster_1113037"; isCluster="true"; label="WholeStageCodegen (4)"; 425937 [id="node_425937" labelType="html" label="MapPartitionsRDD [425937] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113024 { id="cluster_1113024"; isCluster="true"; label="WholeStageCodegen (5)"; 425938 [id="node_425938" labelType="html" label="ZippedPartitionsRDD2 [425938] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425939 [id="node_425939" labelType="html" label="MapPartitionsRDD [425939] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113023 { id="cluster_1113023"; isCluster="true"; label="InMemoryTableScan"; 425940 [id="node_425940" labelType="html" label="MapPartitionsRDD [425940] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425941 [id="node_425941" labelType="html" label="*(5) Project [shardId#6552473, worklistShardItemId#6552474L, version#6869390, qty#6868919, demandChannel#6868899, demandStream#6868900, kpis#6868928]\n+- *(5) SortMergeJoin [shardId#6552473, worklistShardItemId#6552474L], [shardId#6869395, worklistShardItemId#6869396L], Inner\n :- *(2) Sort [shardId#6552473 ASC NULLS FIRST, worklistShardItemId#6552474L ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(shardId#6552473, worklistShardItemId#6552474L, 30), ENSURE_REQUIREMENTS, [plan_id=29067211]\n : +- *(1) Filter (isnotnull(shardId#6552473) AND isnotnull(worklistShardItemId#6552474L))\n : +- InMemoryTableScan [shardId#6552473, worklistShardItemId#6552474L, qty#6868919, demandChannel#6868899, demandStream#6868900, kpis#6868928], [isnotnull(shardId#6552473), isnotnull(worklistShardItemId#6552474L)]\n : +- InMemoryRelation [shardId#6552473, worklistShardItemId#6552474L, qty#6868919, demandChannel#6868899, demandStream#6868900, kpis#6868928], StorageLevel(disk, memory, 2 rep... [425941] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425942 [id="node_425942" labelType="html" label="MapPartitionsRDD [425942] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425943 [id="node_425943" labelType="html" label="MapPartitionsRDD [425943] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425944 [id="node_425944" labelType="html" label="MapPartitionsRDD [425944] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113022 { id="cluster_1113022"; isCluster="true"; label="CollectLimit"; 425945 [id="node_425945" labelType="html" label="MapPartitionsRDD [425945] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425946 [id="node_425946" labelType="html" label="MapPartitionsRDD [425946] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425929->425930; 425936->425937; 425930->425938; 425937->425938; 425938->425939; 425939->425940; 425940->425941; 425941->425942; 425942->425943; 425943->425944; 425944->425945; 425945->425946; }

425928,425929

425935,425936

425941

Event Timeline

Enable zooming