4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1133 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.4 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
6.6 KiB / 87
Shuffle Write Size / Records:
15.9 KiB / 390
Associated Job Ids:
539
DAG Visualization
digraph G { id="graph_1133"; subgraph graph_stage_1133 { id="graph_stage_1133"; isCluster="true"; label="Stage 1133"; subgraph cluster_9189 { id="cluster_9189"; isCluster="true"; label="AQEShuffleRead"; 2980 [id="node_2980" labelType="html" label="ShuffledRowRDD [2980] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9164 { id="cluster_9164"; isCluster="true"; label="WholeStageCodegen (57)"; 2983 [id="node_2983" labelType="html" label="MapPartitionsRDD [2983] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9162 { id="cluster_9162"; isCluster="true"; label="Generate"; 2984 [id="node_2984" labelType="html" label="MapPartitionsRDD [2984] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9161 { id="cluster_9161"; isCluster="true"; label="ObjectHashAggregate"; 2986 [id="node_2986" labelType="html" label="MapPartitionsRDD [2986] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9159 { id="cluster_9159"; isCluster="true"; label="ObjectHashAggregate"; 2988 [id="node_2988" labelType="html" label="MapPartitionsRDD [2988] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9150 { id="cluster_9150"; isCluster="true"; label="WholeStageCodegen (58)"; 2991 [id="node_2991" labelType="html" label="MapPartitionsRDD [2991] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9149 { id="cluster_9149"; isCluster="true"; label="Exchange"; 2992 [id="node_2992" labelType="html" label="MapPartitionsRDD [2992] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 2980->2983; 2983->2984; 2984->2986; 2986->2988; 2988->2991; 2991->2992; }
2979,2980
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