4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 562 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Any: 37
Shuffle Read Size / Records:
3.8 MiB / 49995
Shuffle Write Size / Records:
1655.6 KiB / 39996
Associated Job Ids:
190
DAG Visualization
digraph G { id="graph_562"; subgraph graph_stage_562 { id="graph_stage_562"; isCluster="true"; label="Stage 562"; subgraph cluster_2899 { id="cluster_2899"; isCluster="true"; label="Exchange"; 1058 [id="node_1058" labelType="html" label="ShuffledRowRDD [1058] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2896 { id="cluster_2896"; isCluster="true"; label="WholeStageCodegen (3)"; 1059 [id="node_1059" labelType="html" label="MapPartitionsRDD [1059] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2928 { id="cluster_2928"; isCluster="true"; label="Exchange"; 1068 [id="node_1068" labelType="html" label="ShuffledRowRDD [1068] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2925 { id="cluster_2925"; isCluster="true"; label="WholeStageCodegen (6)"; 1069 [id="node_1069" labelType="html" label="MapPartitionsRDD [1069] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2891 { id="cluster_2891"; isCluster="true"; label="WholeStageCodegen (7)"; 1070 [id="node_1070" labelType="html" label="ZippedPartitionsRDD2 [1070] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 1071 [id="node_1071" labelType="html" label="MapPartitionsRDD [1071] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2890 { id="cluster_2890"; isCluster="true"; label="SortAggregate"; 1072 [id="node_1072" labelType="html" label="MapPartitionsRDD [1072] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_2889 { id="cluster_2889"; isCluster="true"; label="Exchange"; 1073 [id="node_1073" labelType="html" label="MapPartitionsRDD [1073] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 1058->1059; 1068->1069; 1059->1070; 1069->1070; 1070->1071; 1071->1072; 1072->1073; }
1057,1058
1067,1068
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