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

Resource Profile Id: 0
Total Time Across All Tasks: 16 s
Locality Level Summary: Process local: 30
Input Size / Records: 11.5 MiB / 90
Output Size / Records: 2.8 MiB / 445104
Associated Job Ids: 52729

digraph G { id="graph_190946"; subgraph graph_stage_190946 { id="graph_stage_190946"; isCluster="true"; label="Stage 190946"; subgraph cluster_1111727 { id="cluster_1111727"; isCluster="true"; label="Exchange"; 425399 [id="node_425399" labelType="html" label="ShuffledRowRDD [425399] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111724 { id="cluster_1111724"; isCluster="true"; label="WholeStageCodegen (2)"; 425400 [id="node_425400" labelType="html" label="MapPartitionsRDD [425400] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111737 { id="cluster_1111737"; isCluster="true"; label="Exchange"; 425406 [id="node_425406" labelType="html" label="ShuffledRowRDD [425406] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111733 { id="cluster_1111733"; isCluster="true"; label="WholeStageCodegen (4)"; 425407 [id="node_425407" labelType="html" label="MapPartitionsRDD [425407] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111720 { id="cluster_1111720"; isCluster="true"; label="WholeStageCodegen (5)"; 425408 [id="node_425408" labelType="html" label="ZippedPartitionsRDD2 [425408] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425409 [id="node_425409" labelType="html" label="MapPartitionsRDD [425409] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111719 { id="cluster_1111719"; isCluster="true"; label="InMemoryTableScan"; 425410 [id="node_425410" labelType="html" label="MapPartitionsRDD [425410] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425411 [id="node_425411" labelType="html" label="*(5) Project [shardId#6552473, worklistShardItemId#6552474L, version#6861202, qty#6860731, demandChannel#6860711, demandStream#6860712, kpis#6860740]\n+- *(5) SortMergeJoin [shardId#6552473, worklistShardItemId#6552474L], [shardId#6861207, worklistShardItemId#6861208L], 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=29063936]\n : +- *(1) Filter (isnotnull(shardId#6552473) AND isnotnull(worklistShardItemId#6552474L))\n : +- InMemoryTableScan [shardId#6552473, worklistShardItemId#6552474L, qty#6860731, demandChannel#6860711, demandStream#6860712, kpis#6860740], [isnotnull(shardId#6552473), isnotnull(worklistShardItemId#6552474L)]\n : +- InMemoryRelation [shardId#6552473, worklistShardItemId#6552474L, qty#6860731, demandChannel#6860711, demandStream#6860712, kpis#6860740], StorageLevel(disk, memory, 2 rep... [425411] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111773 { id="cluster_1111773"; isCluster="true"; label="InMemoryTableScan"; 425420 [id="node_425420" labelType="html" label="MapPartitionsRDD [425420] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425421 [id="node_425421" labelType="html" label="MapPartitionsRDD [425421] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 425422 [id="node_425422" labelType="html" label="MapPartitionsRDD [425422] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 425399->425400; 425406->425407; 425400->425408; 425407->425408; 425408->425409; 425409->425410; 425410->425411; 425411->425420; 425420->425421; 425421->425422; }

425398,425399

425405,425406

425411

Event Timeline

Enable zooming