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

Resource Profile Id: 0
Total Time Across All Tasks: 12 s
Locality Level Summary: Node local: 30
Shuffle Read Size / Records: 9.7 MiB / 595730
Shuffle Write Size / Records: 1860.0 B / 30
Associated Job Ids: 52517

digraph G { id="graph_189894"; subgraph graph_stage_189894 { id="graph_stage_189894"; isCluster="true"; label="Stage 189894"; subgraph cluster_1104920 { id="cluster_1104920"; isCluster="true"; label="Exchange"; 422659 [id="node_422659" labelType="html" label="ShuffledRowRDD [422659] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104917 { id="cluster_1104917"; isCluster="true"; label="WholeStageCodegen (2)"; 422660 [id="node_422660" labelType="html" label="MapPartitionsRDD [422660] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104930 { id="cluster_1104930"; isCluster="true"; label="Exchange"; 422666 [id="node_422666" labelType="html" label="ShuffledRowRDD [422666] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104926 { id="cluster_1104926"; isCluster="true"; label="WholeStageCodegen (4)"; 422667 [id="node_422667" labelType="html" label="MapPartitionsRDD [422667] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104913 { id="cluster_1104913"; isCluster="true"; label="WholeStageCodegen (5)"; 422668 [id="node_422668" labelType="html" label="ZippedPartitionsRDD2 [422668] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422669 [id="node_422669" labelType="html" label="MapPartitionsRDD [422669] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104912 { id="cluster_1104912"; isCluster="true"; label="InMemoryTableScan"; 422670 [id="node_422670" labelType="html" label="MapPartitionsRDD [422670] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422671 [id="node_422671" labelType="html" label="*(5) Project [shardId#6552497, worklistShardItemId#6552498L, version#6818678, qty#6818207, demandChannel#6818187, demandStream#6818188, kpis#6818216]\n+- *(5) SortMergeJoin [shardId#6552497, worklistShardItemId#6552498L], [shardId#6818683, worklistShardItemId#6818684L], Inner\n :- *(2) Sort [shardId#6552497 ASC NULLS FIRST, worklistShardItemId#6552498L ASC NULLS FIRST], false, 0\n : +- Exchange hashpartitioning(shardId#6552497, worklistShardItemId#6552498L, 30), ENSURE_REQUIREMENTS, [plan_id=29046963]\n : +- *(1) Filter (isnotnull(shardId#6552497) AND isnotnull(worklistShardItemId#6552498L))\n : +- InMemoryTableScan [shardId#6552497, worklistShardItemId#6552498L, qty#6818207, demandChannel#6818187, demandStream#6818188, kpis#6818216], [isnotnull(shardId#6552497), isnotnull(worklistShardItemId#6552498L)]\n : +- InMemoryRelation [shardId#6552497, worklistShardItemId#6552498L, qty#6818207, demandChannel#6818187, demandStream#6818188, kpis#6818216], StorageLevel(disk, memory, 2 rep... [422671] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422672 [id="node_422672" labelType="html" label="MapPartitionsRDD [422672] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422673 [id="node_422673" labelType="html" label="MapPartitionsRDD [422673] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422674 [id="node_422674" labelType="html" label="MapPartitionsRDD [422674] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1104911 { id="cluster_1104911"; isCluster="true"; label="CollectLimit"; 422675 [id="node_422675" labelType="html" label="MapPartitionsRDD [422675] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 422676 [id="node_422676" labelType="html" label="MapPartitionsRDD [422676] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 422659->422660; 422666->422667; 422660->422668; 422667->422668; 422668->422669; 422669->422670; 422670->422671; 422671->422672; 422672->422673; 422673->422674; 422674->422675; 422675->422676; }

422658,422659

422665,422666

422671

Event Timeline

Enable zooming