4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69447 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
212.4 KiB / 2124
Associated Job Ids:
25765
DAG Visualization
digraph G { id="graph_69447"; subgraph graph_stage_69447 { id="graph_stage_69447"; isCluster="true"; label="Stage 69447"; subgraph cluster_515658 { id="cluster_515658"; isCluster="true"; label="Exchange"; 195749 [id="node_195749" labelType="html" label="ShuffledRowRDD [195749] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515623 { id="cluster_515623"; isCluster="true"; label="WholeStageCodegen (3)"; 195750 [id="node_195750" labelType="html" label="MapPartitionsRDD [195750] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515622 { id="cluster_515622"; isCluster="true"; label="ObjectHashAggregate"; 195751 [id="node_195751" labelType="html" label="MapPartitionsRDD [195751] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515621 { id="cluster_515621"; isCluster="true"; label="ObjectHashAggregate"; 195752 [id="node_195752" labelType="html" label="MapPartitionsRDD [195752] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515620 { id="cluster_515620"; isCluster="true"; label="DeserializeToObject"; 195753 [id="node_195753" labelType="html" label="MapPartitionsRDD [195753] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195749->195750; 195750->195751; 195751->195752; 195752->195753; }
195748,195749
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