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

Resource Profile Id: 0
Total Time Across All Tasks: 15 s
Locality Level Summary: Process local: 30
Input Size / Records: 12.5 MiB / 90
Output Size / Records: 3.1 MiB / 479444
Associated Job Ids: 52666

digraph G { id="graph_190648"; subgraph graph_stage_190648 { id="graph_stage_190648"; isCluster="true"; label="Stage 190648"; subgraph cluster_1109715 { id="cluster_1109715"; isCluster="true"; label="Exchange"; 424582 [id="node_424582" labelType="html" label="ShuffledRowRDD [424582] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109712 { id="cluster_1109712"; isCluster="true"; label="WholeStageCodegen (2)"; 424583 [id="node_424583" labelType="html" label="MapPartitionsRDD [424583] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109725 { id="cluster_1109725"; isCluster="true"; label="Exchange"; 424589 [id="node_424589" labelType="html" label="ShuffledRowRDD [424589] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109721 { id="cluster_1109721"; isCluster="true"; label="WholeStageCodegen (4)"; 424590 [id="node_424590" labelType="html" label="MapPartitionsRDD [424590] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109708 { id="cluster_1109708"; isCluster="true"; label="WholeStageCodegen (5)"; 424591 [id="node_424591" labelType="html" label="ZippedPartitionsRDD2 [424591] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424592 [id="node_424592" labelType="html" label="MapPartitionsRDD [424592] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109707 { id="cluster_1109707"; isCluster="true"; label="InMemoryTableScan"; 424593 [id="node_424593" labelType="html" label="MapPartitionsRDD [424593] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424594 [id="node_424594" labelType="html" label="*(5) Project [shardId#6552521, worklistShardItemId#6552522L, version#6848614, qty#6848143, demandChannel#6848123, demandStream#6848124, kpis#6848152]\n+- *(5) SortMergeJoin [shardId#6552521, worklistShardItemId#6552522L], [shardId#6848619, worklistShardItemId#6848620L], Inner\n :- *(2) Sort [shardId#6552521 ASC NULLS FIRST, worklistShardItemId#6552522L ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(shardId#6552521, worklistShardItemId#6552522L, 30), ENSURE_REQUIREMENTS, [plan_id=29058897]\n : +- *(1) Filter (isnotnull(shardId#6552521) AND isnotnull(worklistShardItemId#6552522L))\n : +- InMemoryTableScan [shardId#6552521, worklistShardItemId#6552522L, qty#6848143, demandChannel#6848123, demandStream#6848124, kpis#6848152], [isnotnull(shardId#6552521), isnotnull(worklistShardItemId#6552522L)]\n : +- InMemoryRelation [shardId#6552521, worklistShardItemId#6552522L, qty#6848143, demandChannel#6848123, demandStream#6848124, kpis#6848152], StorageLevel(disk, memory, 2 rep... [424594] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1109761 { id="cluster_1109761"; isCluster="true"; label="InMemoryTableScan"; 424603 [id="node_424603" labelType="html" label="MapPartitionsRDD [424603] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424604 [id="node_424604" labelType="html" label="MapPartitionsRDD [424604] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424605 [id="node_424605" labelType="html" label="MapPartitionsRDD [424605] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 424582->424583; 424589->424590; 424583->424591; 424590->424591; 424591->424592; 424592->424593; 424593->424594; 424594->424603; 424603->424604; 424604->424605; }

424581,424582

424588,424589

424594

Event Timeline

Enable zooming