4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190116 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1.1 min
Locality Level Summary:
Any: 10; Node local: 20
Shuffle Read Size / Records:
7.3 MiB / 79936
Associated Job Ids:
52563
DAG Visualization
digraph G { id="graph_190116"; subgraph graph_stage_190116 { id="graph_stage_190116"; isCluster="true"; label="Stage 190116"; 423225 [id="node_423225" labelType="html" label="SQLExecutionRDD [423225] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1106155 { id="cluster_1106155"; isCluster="true"; label="Exchange"; 423203 [id="node_423203" labelType="html" label="ShuffledRowRDD [423203] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106152 { id="cluster_1106152"; isCluster="true"; label="WholeStageCodegen (19)"; 423204 [id="node_423204" labelType="html" label="MapPartitionsRDD [423204] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106277 { id="cluster_1106277"; isCluster="true"; label="Exchange"; 423217 [id="node_423217" labelType="html" label="ShuffledRowRDD [423217] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106274 { id="cluster_1106274"; isCluster="true"; label="WholeStageCodegen (22)"; 423218 [id="node_423218" labelType="html" label="MapPartitionsRDD [423218] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106147 { id="cluster_1106147"; isCluster="true"; label="WholeStageCodegen (23)"; 423219 [id="node_423219" labelType="html" label="ZippedPartitionsRDD2 [423219] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 423220 [id="node_423220" labelType="html" label="MapPartitionsRDD [423220] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106146 { id="cluster_1106146"; isCluster="true"; label="DeserializeToObject"; 423221 [id="node_423221" labelType="html" label="MapPartitionsRDD [423221] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106145 { id="cluster_1106145"; isCluster="true"; label="MapPartitions"; 423222 [id="node_423222" labelType="html" label="MapPartitionsRDD [423222] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106084 { id="cluster_1106084"; isCluster="true"; label="WholeStageCodegen (26)"; 423223 [id="node_423223" labelType="html" label="MapPartitionsRDD [423223] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106083 { id="cluster_1106083"; isCluster="true"; label="DeserializeToObject"; 423224 [id="node_423224" labelType="html" label="MapPartitionsRDD [423224] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106290 { id="cluster_1106290"; isCluster="true"; label="mapPartitions"; 423226 [id="node_423226" labelType="html" label="MapPartitionsRDD [423226] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106291 { id="cluster_1106291"; isCluster="true"; label="mapPartitions"; 423227 [id="node_423227" labelType="html" label="MapPartitionsRDD [423227] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 423203->423204; 423217->423218; 423204->423219; 423218->423219; 423219->423220; 423220->423221; 423221->423222; 423222->423223; 423223->423224; 423224->423225; 423225->423226; 423226->423227; }
423202,423203
423216,423217
423227
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