4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69306 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
13 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
502.8 KiB / 1048
Associated Job Ids:
25718
DAG Visualization
digraph G { id="graph_69306"; subgraph graph_stage_69306 { id="graph_stage_69306"; isCluster="true"; label="Stage 69306"; 195346 [id="node_195346" labelType="html" label="SQLExecutionRDD [195346] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_514623 { id="cluster_514623"; isCluster="true"; label="Exchange"; 195338 [id="node_195338" labelType="html" label="ShuffledRowRDD [195338] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514622 { id="cluster_514622"; isCluster="true"; label="ObjectHashAggregate"; 195339 [id="node_195339" labelType="html" label="MapPartitionsRDD [195339] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514621 { id="cluster_514621"; isCluster="true"; label="Project"; 195340 [id="node_195340" labelType="html" label="MapPartitionsRDD [195340] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514614 { id="cluster_514614"; isCluster="true"; label="WholeStageCodegen (16)"; 195341 [id="node_195341" labelType="html" label="MapPartitionsRDD [195341] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514613 { id="cluster_514613"; isCluster="true"; label="DeserializeToObject"; 195342 [id="node_195342" labelType="html" label="MapPartitionsRDD [195342] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514612 { id="cluster_514612"; isCluster="true"; label="MapPartitions"; 195343 [id="node_195343" labelType="html" label="MapPartitionsRDD [195343] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514544 { id="cluster_514544"; isCluster="true"; label="WholeStageCodegen (19)"; 195344 [id="node_195344" labelType="html" label="MapPartitionsRDD [195344] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514523 { id="cluster_514523"; isCluster="true"; label="DeserializeToObject"; 195345 [id="node_195345" labelType="html" label="MapPartitionsRDD [195345] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514700 { id="cluster_514700"; isCluster="true"; label="mapPartitions"; 195347 [id="node_195347" labelType="html" label="MapPartitionsRDD [195347] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_514701 { id="cluster_514701"; isCluster="true"; label="mapPartitions"; 195348 [id="node_195348" labelType="html" label="MapPartitionsRDD [195348] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195338->195339; 195339->195340; 195340->195341; 195341->195342; 195342->195343; 195343->195344; 195344->195345; 195345->195346; 195346->195347; 195347->195348; }
195337,195338
195348
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