4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69458 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
483.0 KiB / 1420
Shuffle Write Size / Records:
366.3 KiB / 700
Associated Job Ids:
25769
DAG Visualization
digraph G { id="graph_69458"; subgraph graph_stage_69458 { id="graph_stage_69458"; isCluster="true"; label="Stage 69458"; subgraph cluster_515729 { id="cluster_515729"; isCluster="true"; label="Exchange"; 195770 [id="node_195770" labelType="html" label="ShuffledRowRDD [195770] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515726 { id="cluster_515726"; isCluster="true"; label="WholeStageCodegen (6)"; 195771 [id="node_195771" labelType="html" label="MapPartitionsRDD [195771] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515761 { id="cluster_515761"; isCluster="true"; label="Exchange"; 195781 [id="node_195781" labelType="html" label="ShuffledRowRDD [195781] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515758 { id="cluster_515758"; isCluster="true"; label="WholeStageCodegen (12)"; 195782 [id="node_195782" labelType="html" label="MapPartitionsRDD [195782] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515722 { id="cluster_515722"; isCluster="true"; label="WholeStageCodegen (13)"; 195783 [id="node_195783" labelType="html" label="ZippedPartitionsRDD2 [195783] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 195784 [id="node_195784" labelType="html" label="MapPartitionsRDD [195784] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515721 { id="cluster_515721"; isCluster="true"; label="ObjectHashAggregate"; 195785 [id="node_195785" labelType="html" label="MapPartitionsRDD [195785] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515720 { id="cluster_515720"; isCluster="true"; label="Exchange"; 195786 [id="node_195786" labelType="html" label="MapPartitionsRDD [195786] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195770->195771; 195781->195782; 195771->195783; 195782->195783; 195783->195784; 195784->195785; 195785->195786; }
195769,195770
195780,195781
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