4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 100951 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 34
Shuffle Read Size / Records:
2.9 MiB / 868
Shuffle Write Size / Records:
2.9 MiB / 434
Associated Job Ids:
5445
DAG Visualization
digraph G { id="graph_100951"; subgraph graph_stage_100951 { id="graph_stage_100951"; isCluster="true"; label="Stage 100951"; subgraph cluster_123308 { id="cluster_123308"; isCluster="true"; label="AQEShuffleRead"; 47446 [id="node_47446" labelType="html" label="ShuffledRowRDD [47446] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123305 { id="cluster_123305"; isCluster="true"; label="WholeStageCodegen (61)"; 47447 [id="node_47447" labelType="html" label="MapPartitionsRDD [47447] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123313 { id="cluster_123313"; isCluster="true"; label="AQEShuffleRead"; 47448 [id="node_47448" labelType="html" label="ShuffledRowRDD [47448] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123310 { id="cluster_123310"; isCluster="true"; label="WholeStageCodegen (62)"; 47449 [id="node_47449" labelType="html" label="MapPartitionsRDD [47449] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123301 { id="cluster_123301"; isCluster="true"; label="WholeStageCodegen (63)"; 47450 [id="node_47450" labelType="html" label="ZippedPartitionsRDD2 [47450] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 47451 [id="node_47451" labelType="html" label="MapPartitionsRDD [47451] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123300 { id="cluster_123300"; isCluster="true"; label="ObjectHashAggregate"; 47452 [id="node_47452" labelType="html" label="MapPartitionsRDD [47452] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_123299 { id="cluster_123299"; isCluster="true"; label="Exchange"; 47453 [id="node_47453" labelType="html" label="MapPartitionsRDD [47453] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 47446->47447; 47448->47449; 47447->47450; 47449->47450; 47450->47451; 47451->47452; 47452->47453; }
47445,47446
47340,47448
Event Timeline
Enable zooming
Tasks: 34. 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