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

Resource Profile Id: 0
Total Time Across All Tasks: 4 s
Locality Level Summary: Process local: 37
Input Size / Records: 16.4 MiB / 37
Shuffle Write Size / Records: 782.9 KiB / 56448
Associated Job Ids: 52693

digraph G { id="graph_1032841"; subgraph graph_stage_1032841 { id="graph_stage_1032841"; isCluster="true"; label="Stage 1032841"; subgraph cluster_1087598 { id="cluster_1087598"; isCluster="true"; label="Exchange"; 434120 [id="node_434120" labelType="html" label="ShuffledRowRDD [434120] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1087594 { id="cluster_1087594"; isCluster="true"; label="WholeStageCodegen (2)"; 434121 [id="node_434121" labelType="html" label="MapPartitionsRDD [434121] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1087599 { id="cluster_1087599"; isCluster="true"; label="mapPartitionsInternal"; 434122 [id="node_434122" labelType="html" label="MapPartitionsRDD [434122] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_1087600 { id="cluster_1087600"; isCluster="true"; label="mapPartitionsInternal"; 434123 [id="node_434123" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [0_4_10000000540 AS shardId#10205815, worklistShardItemId#10206042L, orderProposalId#10206019L, orderProposalItemId#10206020, orderProposalItemGroupId#10206043, originalReplenishmentRunId#10206061L, orderProposalHorizonGroupingId#10206037L, splitIndicator#10206038L, previousOrderProposal#10206039L, clusterId#10206040L, cast(sequenceId#10206041 as bigint) AS sequenceId#10205825L, sourceOfSupplyUuid#10206033, supplierGroup#10206021, supplier#10206022, subrange#10206025, product#10206028, plant#10206023, purchasingOrg#10206034, purchasingGroup#10206035, mrpController#10206032, orderDateTime#10206029, deliveryDateTime#10206024, availabilityDateTime#10206030, nextAvailabilityDateTime#10206031, isFallbackOrderOnly#10206036, ... 20 more fields]\n +- Exchange hashpartitioning(worklistShardItemId#10206042L, 37), REPARTITION_BY_NUM, [plan_id=3017883]\n +- Project [orderProposalId#10206019L, orderProposalItemId#10206020, supplierGroup#10206021, supplier#10206022, pl... [434123] [Cached] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_1087768 { id="cluster_1087768"; isCluster="true"; label="InMemoryTableScan"; 434196 [id="node_434196" labelType="html" label="MapPartitionsRDD [434196] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 434197 [id="node_434197" labelType="html" label="MapPartitionsRDD [434197] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 434198 [id="node_434198" labelType="html" label="MapPartitionsRDD [434198] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1087761 { id="cluster_1087761"; isCluster="true"; label="WholeStageCodegen (2)"; 434199 [id="node_434199" labelType="html" label="MapPartitionsRDD [434199] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1087760 { id="cluster_1087760"; isCluster="true"; label="Exchange"; 434200 [id="node_434200" labelType="html" label="MapPartitionsRDD [434200] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 434120->434121; 434121->434122; 434122->434123; 434123->434196; 434196->434197; 434197->434198; 434198->434199; 434199->434200; }

434119,434120

434123

Event Timeline

Enable zooming