4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 116507 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 37
Shuffle Read Size / Records:
684.0 KiB / 458
Shuffle Write Size / Records:
577.0 KiB / 143
Associated Job Ids:
6407
DAG Visualization
digraph G { id="graph_116507"; subgraph graph_stage_116507 { id="graph_stage_116507"; isCluster="true"; label="Stage 116507"; subgraph cluster_146175 { id="cluster_146175"; isCluster="true"; label="Exchange"; 56253 [id="node_56253" labelType="html" label="ShuffledRowRDD [56253] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146172 { id="cluster_146172"; isCluster="true"; label="WholeStageCodegen (4)"; 56254 [id="node_56254" labelType="html" label="MapPartitionsRDD [56254] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146195 { id="cluster_146195"; isCluster="true"; label="Exchange"; 56264 [id="node_56264" labelType="html" label="ShuffledRowRDD [56264] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146192 { id="cluster_146192"; isCluster="true"; label="WholeStageCodegen (8)"; 56265 [id="node_56265" labelType="html" label="MapPartitionsRDD [56265] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146168 { id="cluster_146168"; isCluster="true"; label="WholeStageCodegen (9)"; 56266 [id="node_56266" labelType="html" label="ZippedPartitionsRDD2 [56266] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 56267 [id="node_56267" labelType="html" label="MapPartitionsRDD [56267] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146167 { id="cluster_146167"; isCluster="true"; label="ObjectHashAggregate"; 56268 [id="node_56268" labelType="html" label="MapPartitionsRDD [56268] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146166 { id="cluster_146166"; isCluster="true"; label="Exchange"; 56269 [id="node_56269" labelType="html" label="MapPartitionsRDD [56269] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56253->56254; 56264->56265; 56254->56266; 56265->56266; 56266->56267; 56267->56268; 56268->56269; }
56252,56253
56263,56264
Event Timeline
Enable zooming
Tasks: 37. 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