4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1190 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
6.6 KiB / 87
Shuffle Write Size / Records:
17.7 KiB / 390
Associated Job Ids:
565
DAG Visualization
digraph G { id="graph_1190"; subgraph graph_stage_1190 { id="graph_stage_1190"; isCluster="true"; label="Stage 1190"; subgraph cluster_9796 { id="cluster_9796"; isCluster="true"; label="AQEShuffleRead"; 3071 [id="node_3071" labelType="html" label="ShuffledRowRDD [3071] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9767 { id="cluster_9767"; isCluster="true"; label="WholeStageCodegen (289)"; 3073 [id="node_3073" labelType="html" label="MapPartitionsRDD [3073] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9766 { id="cluster_9766"; isCluster="true"; label="Generate"; 3074 [id="node_3074" labelType="html" label="MapPartitionsRDD [3074] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9765 { id="cluster_9765"; isCluster="true"; label="ObjectHashAggregate"; 3075 [id="node_3075" labelType="html" label="MapPartitionsRDD [3075] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9764 { id="cluster_9764"; isCluster="true"; label="ObjectHashAggregate"; 3076 [id="node_3076" labelType="html" label="MapPartitionsRDD [3076] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9750 { id="cluster_9750"; isCluster="true"; label="WholeStageCodegen (290)"; 3077 [id="node_3077" labelType="html" label="MapPartitionsRDD [3077] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9749 { id="cluster_9749"; isCluster="true"; label="Exchange"; 3078 [id="node_3078" labelType="html" label="MapPartitionsRDD [3078] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 3071->3073; 3073->3074; 3074->3075; 3075->3076; 3076->3077; 3077->3078; }
3070,3071
Event Timeline
Enable zooming
Tasks: 1. 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