4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446504 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.6 s
Locality Level Summary:
Node local: 20
Shuffle Read Size / Records:
34.4 KiB / 256
Associated Job Ids:
154927
DAG Visualization
digraph G { id="graph_446504"; subgraph graph_stage_446504 { id="graph_stage_446504"; isCluster="true"; label="Stage 446504"; subgraph cluster_3153719 { id="cluster_3153719"; isCluster="true"; label="Exchange"; 1244067 [id="node_1244067" labelType="html" label="ShuffledRowRDD [1244067] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153684 { id="cluster_3153684"; isCluster="true"; label="WholeStageCodegen (3)"; 1244068 [id="node_1244068" labelType="html" label="MapPartitionsRDD [1244068] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153683 { id="cluster_3153683"; isCluster="true"; label="ObjectHashAggregate"; 1244069 [id="node_1244069" labelType="html" label="MapPartitionsRDD [1244069] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153682 { id="cluster_3153682"; isCluster="true"; label="ObjectHashAggregate"; 1244070 [id="node_1244070" labelType="html" label="MapPartitionsRDD [1244070] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153681 { id="cluster_3153681"; isCluster="true"; label="DeserializeToObject"; 1244071 [id="node_1244071" labelType="html" label="MapPartitionsRDD [1244071] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1244067->1244068; 1244068->1244069; 1244069->1244070; 1244070->1244071; }
1244066,1244067
Event Timeline
Enable zooming
Tasks: 20. 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