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

Resource Profile Id: 0
Total Time Across All Tasks: 13 s
Locality Level Summary: Process local: 30
Input Size / Records: 4.2 MiB / 30
Output Size / Records: 1121.5 KiB / 159872
Associated Job Ids: 52770

digraph G { id="graph_191141"; subgraph graph_stage_191141 { id="graph_stage_191141"; isCluster="true"; label="Stage 191141"; 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}"]; } subgraph cluster_1113077 { id="cluster_1113077"; isCluster="true"; label="InMemoryTableScan"; 425950 [id="node_425950" labelType="html" label="MapPartitionsRDD [425950] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425951 [id="node_425951" labelType="html" label="MapPartitionsRDD [425951] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425952 [id="node_425952" labelType="html" label="MapPartitionsRDD [425952] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425929->425930; 425936->425937; 425930->425938; 425937->425938; 425938->425939; 425939->425940; 425940->425941; 425941->425950; 425950->425951; 425951->425952; }

425928,425929

425935,425936

425941

Event Timeline

Enable zooming