3.5.5
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 332 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Node local: 25
Shuffle Read Size / Records:
166.5 KiB / 1196
Shuffle Write Size / Records:
328.7 KiB / 1032
Associated Job Ids:
181
DAG Visualization
digraph G { subgraph clusterstage_332 { label="Stage 332"; subgraph cluster2503 { label="Exchange"; 933 [labelType="html" label="ShuffledRowRDD [933] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } subgraph cluster2499 { label="WholeStageCodegen (5)"; 934 [labelType="html" label="MapPartitionsRDD [934] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } subgraph cluster2498 { label="WindowGroupLimit"; 935 [labelType="html" label="MapPartitionsRDD [935] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } subgraph cluster2497 { label="Window"; 936 [labelType="html" label="MapPartitionsRDD [936] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } subgraph cluster2481 { label="WholeStageCodegen (6)"; 937 [labelType="html" label="MapPartitionsRDD [937] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } subgraph cluster2480 { label="ObjectHashAggregate"; 938 [labelType="html" label="MapPartitionsRDD [938] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } subgraph cluster2479 { label="Exchange"; 939 [labelType="html" label="MapPartitionsRDD [939] [Unordered]<br>save at FileStorageAdapterImpl.java:561"]; } } 933->934; 934->935; 935->936; 936->937; 937->938; 938->939; }
915,933
Event Timeline
Enable zooming
Tasks: 25. 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