4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1032533 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 37
Associated Job Ids:
52680
DAG Visualization
digraph G { id="graph_1032533"; subgraph graph_stage_1032533 { id="graph_stage_1032533"; isCluster="true"; label="Stage 1032533"; subgraph cluster_1087572 { id="cluster_1087572"; isCluster="true"; label="Exchange"; 434107 [id="node_434107" labelType="html" label="ShuffledRowRDD [434107] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1087568 { id="cluster_1087568"; isCluster="true"; label="WholeStageCodegen (2)"; 434108 [id="node_434108" labelType="html" label="MapPartitionsRDD [434108] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1087573 { id="cluster_1087573"; isCluster="true"; label="mapPartitionsInternal"; 434109 [id="node_434109" labelType="html" label="MapPartitionsRDD [434109] [Unordered]<br>isEmpty at OrderQuantityOptimizationImpl.java:183}"]; } subgraph cluster_1087574 { id="cluster_1087574"; isCluster="true"; label="mapPartitionsInternal"; 434110 [id="node_434110" 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=3017808]\n +- Project [orderProposalId#10206019L, orderProposalItemId#10206020, supplierGroup#10206021, supplier#10206022, pl... [434110] [Cached] [Unordered]<br>isEmpty at OrderQuantityOptimizationImpl.java:183}"]; } } 434107->434108; 434108->434109; 434109->434110; }
434106,434107
434110
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