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

Resource Profile Id: 0
Total Time Across All Tasks: 3 s
Locality Level Summary: Process local: 37
Input Size / Records: 8.2 MiB / 37
Shuffle Write Size / Records: 2.2 KiB / 37
Associated Job Ids: 114621

digraph G { id="graph_2133673"; subgraph graph_stage_2133673 { id="graph_stage_2133673"; isCluster="true"; label="Stage 2133673"; subgraph cluster_2365488 { id="cluster_2365488"; isCluster="true"; label="Exchange"; 942879 [id="node_942879" labelType="html" label="ShuffledRowRDD [942879] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2365484 { id="cluster_2365484"; isCluster="true"; label="WholeStageCodegen (2)"; 942880 [id="node_942880" labelType="html" label="MapPartitionsRDD [942880] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2365489 { id="cluster_2365489"; isCluster="true"; label="mapPartitionsInternal"; 942881 [id="node_942881" labelType="html" label="MapPartitionsRDD [942881] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_2365490 { id="cluster_2365490"; isCluster="true"; label="mapPartitionsInternal"; 942882 [id="node_942882" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- Project [0_7_10000000553 AS shardId#22188188, worklistShardItemId#22188256L, orderProposalId#22188233L, orderProposalItemId#22188234, orderProposalItemGroupId#22188257, originalReplenishmentRunId#22188275L, orderProposalHorizonGroupingId#22188251L, splitIndicator#22188252L, previousOrderProposal#22188253L, clusterId#22188254L, cast(sequenceId#22188255 as bigint) AS sequenceId#22188198L, sourceOfSupplyUuid#22188247, supplierGroup#22188235, supplier#22188236, subrange#22188239, product#22188242, plant#22188237, purchasingOrg#22188248, purchasingGroup#22188249, mrpController#22188246, orderDateTime#22188243, deliveryDateTime#22188238, availabilityDateTime#22188244, nextAvailabilityDateTime#22188245, isFallbackOrderOnly#22188250, ... 20 more fields]\n +- Exchange hashpartitioning(worklistShardItemId#22188256L, 37), REPARTITION_BY_NUM, [plan_id=6642645]\n +- Project [orderProposalId#22188233L, orderProposalItemId#22188234, supplierGroup#22188235, supplier#22188236, pl... [942882] [Cached] [Unordered] isEmpty at OrderQuantityOptimizationImpl.java:151}"]; } subgraph cluster_2365493 { id="cluster_2365493"; isCluster="true"; label="InMemoryTableScan"; 942883 [id="node_942883" labelType="html" label="MapPartitionsRDD [942883] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 942884 [id="node_942884" labelType="html" label="MapPartitionsRDD [942884] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 942885 [id="node_942885" labelType="html" label="MapPartitionsRDD [942885] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2365491 { id="cluster_2365491"; isCluster="true"; label="CollectLimit"; 942886 [id="node_942886" labelType="html" label="MapPartitionsRDD [942886] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 942887 [id="node_942887" labelType="html" label="MapPartitionsRDD [942887] [Unordered] $anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 942879->942880; 942880->942881; 942881->942882; 942882->942883; 942883->942884; 942884->942885; 942885->942886; 942886->942887; }

942878,942879

942882

Event Timeline

Enable zooming