4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101345 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 37
Shuffle Read Size / Records:
22.5 KiB / 434
Shuffle Write Size / Records:
14.7 KiB / 139
Associated Job Ids:
5593
DAG Visualization
digraph G { id="graph_101345"; subgraph graph_stage_101345 { id="graph_stage_101345"; isCluster="true"; label="Stage 101345"; subgraph cluster_125883 { id="cluster_125883"; isCluster="true"; label="Exchange"; 48153 [id="node_48153" labelType="html" label="ShuffledRowRDD [48153] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125869 { id="cluster_125869"; isCluster="true"; label="WholeStageCodegen (43)"; 48154 [id="node_48154" labelType="html" label="MapPartitionsRDD [48154] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125868 { id="cluster_125868"; isCluster="true"; label="Project"; 48155 [id="node_48155" labelType="html" label="MapPartitionsRDD [48155] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125861 { id="cluster_125861"; isCluster="true"; label="WholeStageCodegen (44)"; 48156 [id="node_48156" labelType="html" label="MapPartitionsRDD [48156] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125860 { id="cluster_125860"; isCluster="true"; label="Exchange"; 48157 [id="node_48157" labelType="html" label="MapPartitionsRDD [48157] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 48153->48154; 48154->48155; 48155->48156; 48156->48157; }
48036,48153
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