4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 779 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 10
Shuffle Read Size / Records:
8.8 KiB / 195
Associated Job Ids:
380
DAG Visualization
digraph G { id="graph_779"; subgraph graph_stage_779 { id="graph_stage_779"; isCluster="true"; label="Stage 779"; subgraph cluster_6546 { id="cluster_6546"; isCluster="true"; label="Exchange"; 1949 [id="node_1949" labelType="html" label="ShuffledRowRDD [1949] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_6529 { id="cluster_6529"; isCluster="true"; label="WholeStageCodegen (7)"; 1950 [id="node_1950" labelType="html" label="MapPartitionsRDD [1950] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_6528 { id="cluster_6528"; isCluster="true"; label="Project"; 1951 [id="node_1951" labelType="html" label="MapPartitionsRDD [1951] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_6515 { id="cluster_6515"; isCluster="true"; label="WholeStageCodegen (8)"; 1952 [id="node_1952" labelType="html" label="MapPartitionsRDD [1952] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_6547 { id="cluster_6547"; isCluster="true"; label="mapPartitionsInternal"; 1953 [id="node_1953" labelType="html" label="MapPartitionsRDD [1953] [Unordered]<br>isEmpty at InsightHandlerImpl.java:57}"]; } subgraph cluster_6548 { id="cluster_6548"; isCluster="true"; label="mapPartitionsInternal"; 1954 [id="node_1954" labelType="html" label="AdaptiveSparkPlan isFinalPlan=false\n+- HashAggregate(keys=[product#25911, plant#25912], functions=[], output=[name#26328, configurationVersion#26329, executionId#26335, createdAt#26337, marketUnit#26336, businessContext#26334])\n +- HashAggregate(keys=[product#25911, plant#25912], functions=[], output=[product#25911, plant#25912])\n +- Project [product#25911, plant#25912]\n +- Filter (((size(demandTimeBuckets#26323, true) = 0) OR isnull(demandTimeBuckets#26323)) AND ((size(demandPointInTime#26326, true) = 0) OR isnull(demandPointInTime#26326)))\n +- BroadcastHashJoin [product#25911, plant#25912], [product#26318, plant#26319], LeftOuter, BuildRight, false\n :- Project [product#25911, plant#25912]\n : +- Generate explode(_extract_quantityDenominator#38665), [product#25911, plant#25912], true, [quantityDenominator#25968]\n : +- Project [product#25911, plant#25912, filteredUnitOfMeasureConversions#25957.quantityDenominator AS _extract_quantityDe... [1954] [Cached] [Unordered]<br>isEmpty at InsightHandlerImpl.java:57}"]; } } 1949->1950; 1950->1951; 1951->1952; 1952->1953; 1953->1954; }
1930,1949
1954
Event Timeline
Enable zooming
Tasks: 10. 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