4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 173269 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 1; Process local: 29
Shuffle Read Size / Records:
8.6 KiB / 2
Associated Job Ids:
60595
DAG Visualization
digraph G { id="graph_173269"; subgraph graph_stage_173269 { id="graph_stage_173269"; isCluster="true"; label="Stage 173269"; 483911 [id="node_483911" labelType="html" label="SQLExecutionRDD [483911] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1243835 { id="cluster_1243835"; isCluster="true"; label="Exchange"; 483903 [id="node_483903" labelType="html" label="ShuffledRowRDD [483903] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243834 { id="cluster_1243834"; isCluster="true"; label="ObjectHashAggregate"; 483904 [id="node_483904" labelType="html" label="MapPartitionsRDD [483904] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243833 { id="cluster_1243833"; isCluster="true"; label="Project"; 483905 [id="node_483905" labelType="html" label="MapPartitionsRDD [483905] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243812 { id="cluster_1243812"; isCluster="true"; label="WholeStageCodegen (16)"; 483906 [id="node_483906" labelType="html" label="MapPartitionsRDD [483906] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243811 { id="cluster_1243811"; isCluster="true"; label="DeserializeToObject"; 483907 [id="node_483907" labelType="html" label="MapPartitionsRDD [483907] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243810 { id="cluster_1243810"; isCluster="true"; label="MapPartitions"; 483908 [id="node_483908" labelType="html" label="MapPartitionsRDD [483908] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243756 { id="cluster_1243756"; isCluster="true"; label="WholeStageCodegen (19)"; 483909 [id="node_483909" labelType="html" label="MapPartitionsRDD [483909] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243735 { id="cluster_1243735"; isCluster="true"; label="DeserializeToObject"; 483910 [id="node_483910" labelType="html" label="MapPartitionsRDD [483910] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243912 { id="cluster_1243912"; isCluster="true"; label="mapPartitions"; 483912 [id="node_483912" labelType="html" label="MapPartitionsRDD [483912] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243913 { id="cluster_1243913"; isCluster="true"; label="mapPartitions"; 483913 [id="node_483913" labelType="html" label="MapPartitionsRDD [483913] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 483903->483904; 483904->483905; 483905->483906; 483906->483907; 483907->483908; 483908->483909; 483909->483910; 483910->483911; 483911->483912; 483912->483913; }
483902,483903
483913
Event Timeline
Enable zooming
Tasks: 30. 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