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

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

digraph G { id="graph_190454"; subgraph graph_stage_190454 { id="graph_stage_190454"; isCluster="true"; label="Stage 190454"; subgraph cluster_1108433 { id="cluster_1108433"; isCluster="true"; label="Exchange"; 424060 [id="node_424060" labelType="html" label="ShuffledRowRDD [424060] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108430 { id="cluster_1108430"; isCluster="true"; label="WholeStageCodegen (2)"; 424061 [id="node_424061" labelType="html" label="MapPartitionsRDD [424061] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108443 { id="cluster_1108443"; isCluster="true"; label="Exchange"; 424067 [id="node_424067" labelType="html" label="ShuffledRowRDD [424067] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108439 { id="cluster_1108439"; isCluster="true"; label="WholeStageCodegen (4)"; 424068 [id="node_424068" labelType="html" label="MapPartitionsRDD [424068] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108426 { id="cluster_1108426"; isCluster="true"; label="WholeStageCodegen (5)"; 424069 [id="node_424069" labelType="html" label="ZippedPartitionsRDD2 [424069] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424070 [id="node_424070" labelType="html" label="MapPartitionsRDD [424070] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108425 { id="cluster_1108425"; isCluster="true"; label="InMemoryTableScan"; 424071 [id="node_424071" labelType="html" label="MapPartitionsRDD [424071] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424072 [id="node_424072" labelType="html" label="*(5) Project [shardId#6552521, worklistShardItemId#6552522L, version#6840458, qty#6839987, demandChannel#6839967, demandStream#6839968, kpis#6839996]\n+- *(5) SortMergeJoin [shardId#6552521, worklistShardItemId#6552522L], [shardId#6840463, worklistShardItemId#6840464L], 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=29055655]\n : +- *(1) Filter (isnotnull(shardId#6552521) AND isnotnull(worklistShardItemId#6552522L))\n : +- InMemoryTableScan [shardId#6552521, worklistShardItemId#6552522L, qty#6839987, demandChannel#6839967, demandStream#6839968, kpis#6839996], [isnotnull(shardId#6552521), isnotnull(worklistShardItemId#6552522L)]\n : +- InMemoryRelation [shardId#6552521, worklistShardItemId#6552522L, qty#6839987, demandChannel#6839967, demandStream#6839968, kpis#6839996], StorageLevel(disk, memory, 2 rep... [424072] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1108479 { id="cluster_1108479"; isCluster="true"; label="InMemoryTableScan"; 424081 [id="node_424081" labelType="html" label="MapPartitionsRDD [424081] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424082 [id="node_424082" labelType="html" label="MapPartitionsRDD [424082] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 424083 [id="node_424083" labelType="html" label="MapPartitionsRDD [424083] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 424060->424061; 424067->424068; 424061->424069; 424068->424069; 424069->424070; 424070->424071; 424071->424072; 424072->424081; 424081->424082; 424082->424083; }

424059,424060

424066,424067

424072

Event Timeline

Enable zooming