4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 2133666 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 37
Associated Job Ids:
114617
DAG Visualization
digraph G { id="graph_2133666"; subgraph graph_stage_2133666 { id="graph_stage_2133666"; isCluster="true"; label="Stage 2133666"; subgraph cluster_2365462 { id="cluster_2365462"; isCluster="true"; label="Exchange"; 942866 [id="node_942866" labelType="html" label="ShuffledRowRDD [942866] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2365458 { id="cluster_2365458"; isCluster="true"; label="WholeStageCodegen (2)"; 942867 [id="node_942867" labelType="html" label="MapPartitionsRDD [942867] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_2365463 { id="cluster_2365463"; isCluster="true"; label="mapPartitionsInternal"; 942868 [id="node_942868" labelType="html" label="MapPartitionsRDD [942868] [Unordered]<br>isEmpty at OrderQuantityOptimizationImpl.java:183}"]; } subgraph cluster_2365464 { id="cluster_2365464"; isCluster="true"; label="mapPartitionsInternal"; 942869 [id="node_942869" 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=6642570]\n +- Project [orderProposalId#22188233L, orderProposalItemId#22188234, supplierGroup#22188235, supplier#22188236, pl... [942869] [Cached] [Unordered]<br>isEmpty at OrderQuantityOptimizationImpl.java:183}"]; } } 942866->942867; 942867->942868; 942868->942869; }
942865,942866
942869
Event Timeline
Enable zooming
Tasks: 37. 1 Pages. Jump to
. Show
items in a page.
Go
Scheduler Delay
Task Deserialization Time
Shuffle Read Time
Executor Computing Time
Shuffle Write Time
Result Serialization Time
Getting Result Time