crp-order-qty-opt-service - Details for Stage 341305 (Attempt 0)

Resource Profile Id: 0
Total Time Across All Tasks: 8 s
Locality Level Summary: Process local: 37
Input Size / Records: 19.1 MiB / 37
Shuffle Write Size / Records: 2.2 MiB / 65484
Associated Job Ids: 18761

digraph G { id="graph_341305"; subgraph graph_stage_341305 { id="graph_stage_341305"; isCluster="true"; label="Stage 341305"; subgraph cluster_386086 { id="cluster_386086"; isCluster="true"; label="Exchange"; 154395 [id="node_154395" labelType="html" label="ShuffledRowRDD [154395] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386082 { id="cluster_386082"; isCluster="true"; label="WholeStageCodegen (2)"; 154396 [id="node_154396" labelType="html" label="MapPartitionsRDD [154396] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386087 { id="cluster_386087"; isCluster="true"; label="mapPartitionsInternal"; 154397 [id="node_154397" labelType="html" label="MapPartitionsRDD [154397] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_386088 { id="cluster_386088"; isCluster="true"; label="mapPartitionsInternal"; 154398 [id="node_154398" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [0_5_10000000532 AS shardId#3617984, worklistShardItemId#3618052L, orderProposalId#3618029L, orderProposalItemId#3618030, orderProposalItemGroupId#3618053, originalReplenishmentRunId#3618071L, orderProposalHorizonGroupingId#3618047L, splitIndicator#3618048L, previousOrderProposal#3618049L, clusterId#3618050L, cast(sequenceId#3618051 as bigint) AS sequenceId#3617994L, sourceOfSupplyUuid#3618043, supplierGroup#3618031, supplier#3618032, subrange#3618035, product#3618038, plant#3618033, purchasingOrg#3618044, purchasingGroup#3618045, mrpController#3618042, orderDateTime#3618039, deliveryDateTime#3618034, availabilityDateTime#3618040, nextAvailabilityDateTime#3618041, isFallbackOrderOnly#3618046, ... 20 more fields]\n +- Exchange hashpartitioning(worklistShardItemId#3618052L, 37), REPARTITION_BY_NUM, [plan_id=1036246]\n +- Project [orderProposalId#3618029L, orderProposalItemId#3618030, supplierGroup#3618031, supplier#3618032, plant#3618033, deliveryDateTime#3... [154398] [Cached] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_386176 { id="cluster_386176"; isCluster="true"; label="InMemoryTableScan"; 154433 [id="node_154433" labelType="html" label="MapPartitionsRDD [154433] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154434 [id="node_154434" labelType="html" label="MapPartitionsRDD [154434] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 154435 [id="node_154435" labelType="html" label="MapPartitionsRDD [154435] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386166 { id="cluster_386166"; isCluster="true"; label="WholeStageCodegen (1)"; 154436 [id="node_154436" labelType="html" label="MapPartitionsRDD [154436] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386165 { id="cluster_386165"; isCluster="true"; label="ObjectHashAggregate"; 154437 [id="node_154437" labelType="html" label="MapPartitionsRDD [154437] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_386164 { id="cluster_386164"; isCluster="true"; label="Exchange"; 154438 [id="node_154438" labelType="html" label="MapPartitionsRDD [154438] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 154395->154396; 154396->154397; 154397->154398; 154398->154433; 154433->154434; 154434->154435; 154435->154436; 154436->154437; 154437->154438; }

154394,154395

154398

Event Timeline

Enable zooming