4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 172355 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
14 s
Locality Level Summary:
Node local: 21; Process local: 9
Shuffle Read Size / Records:
204.6 KiB / 54
Associated Job Ids:
60289
DAG Visualization
digraph G { id="graph_172355"; subgraph graph_stage_172355 { id="graph_stage_172355"; isCluster="true"; label="Stage 172355"; 481275 [id="node_481275" labelType="html" label="SQLExecutionRDD [481275] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1237369 { id="cluster_1237369"; isCluster="true"; label="Exchange"; 481267 [id="node_481267" labelType="html" label="ShuffledRowRDD [481267] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237368 { id="cluster_1237368"; isCluster="true"; label="ObjectHashAggregate"; 481268 [id="node_481268" labelType="html" label="MapPartitionsRDD [481268] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237367 { id="cluster_1237367"; isCluster="true"; label="Project"; 481269 [id="node_481269" labelType="html" label="MapPartitionsRDD [481269] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237360 { id="cluster_1237360"; isCluster="true"; label="WholeStageCodegen (16)"; 481270 [id="node_481270" labelType="html" label="MapPartitionsRDD [481270] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237359 { id="cluster_1237359"; isCluster="true"; label="DeserializeToObject"; 481271 [id="node_481271" labelType="html" label="MapPartitionsRDD [481271] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237358 { id="cluster_1237358"; isCluster="true"; label="MapPartitions"; 481272 [id="node_481272" labelType="html" label="MapPartitionsRDD [481272] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237290 { id="cluster_1237290"; isCluster="true"; label="WholeStageCodegen (19)"; 481273 [id="node_481273" labelType="html" label="MapPartitionsRDD [481273] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237269 { id="cluster_1237269"; isCluster="true"; label="DeserializeToObject"; 481274 [id="node_481274" labelType="html" label="MapPartitionsRDD [481274] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237446 { id="cluster_1237446"; isCluster="true"; label="mapPartitions"; 481276 [id="node_481276" labelType="html" label="MapPartitionsRDD [481276] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1237447 { id="cluster_1237447"; isCluster="true"; label="mapPartitions"; 481277 [id="node_481277" labelType="html" label="MapPartitionsRDD [481277] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 481267->481268; 481268->481269; 481269->481270; 481270->481271; 481271->481272; 481272->481273; 481273->481274; 481274->481275; 481275->481276; 481276->481277; }
481266,481267
481277
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