4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 880 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 8
Shuffle Read Size / Records:
71.7 KiB / 368
Associated Job Ids:
416
DAG Visualization
digraph G { id="graph_880"; subgraph graph_stage_880 { id="graph_stage_880"; isCluster="true"; label="Stage 880"; 2284 [id="node_2284" labelType="html" label="SQLExecutionRDD [2284] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_7254 { id="cluster_7254"; isCluster="true"; label="Exchange"; 2276 [id="node_2276" labelType="html" label="ShuffledRowRDD [2276] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7253 { id="cluster_7253"; isCluster="true"; label="ObjectHashAggregate"; 2277 [id="node_2277" labelType="html" label="MapPartitionsRDD [2277] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7252 { id="cluster_7252"; isCluster="true"; label="Project"; 2278 [id="node_2278" labelType="html" label="MapPartitionsRDD [2278] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7245 { id="cluster_7245"; isCluster="true"; label="WholeStageCodegen (11)"; 2279 [id="node_2279" labelType="html" label="MapPartitionsRDD [2279] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7244 { id="cluster_7244"; isCluster="true"; label="DeserializeToObject"; 2280 [id="node_2280" labelType="html" label="MapPartitionsRDD [2280] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7243 { id="cluster_7243"; isCluster="true"; label="MapPartitions"; 2281 [id="node_2281" labelType="html" label="MapPartitionsRDD [2281] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7185 { id="cluster_7185"; isCluster="true"; label="WholeStageCodegen (14)"; 2282 [id="node_2282" labelType="html" label="MapPartitionsRDD [2282] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7170 { id="cluster_7170"; isCluster="true"; label="DeserializeToObject"; 2283 [id="node_2283" labelType="html" label="MapPartitionsRDD [2283] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7304 { id="cluster_7304"; isCluster="true"; label="mapPartitions"; 2285 [id="node_2285" labelType="html" label="MapPartitionsRDD [2285] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7305 { id="cluster_7305"; isCluster="true"; label="mapPartitions"; 2286 [id="node_2286" labelType="html" label="MapPartitionsRDD [2286] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 2276->2277; 2277->2278; 2278->2279; 2279->2280; 2280->2281; 2281->2282; 2282->2283; 2283->2284; 2284->2285; 2285->2286; }
2275,2276
2286
Event Timeline
Enable zooming
Tasks: 8. 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