3.5.5
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 146 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
14 ms
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
1239.0 B / 8
Shuffle Write Size / Records:
892.0 B / 4
Associated Job Ids:
73
DAG Visualization
digraph G { subgraph clusterstage_146 { label="Stage 146"; subgraph cluster917 { label="AQEShuffleRead"; 360 [labelType="html" label="ShuffledRowRDD [360] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; } subgraph cluster914 { label="WholeStageCodegen (1)"; 361 [labelType="html" label="MapPartitionsRDD [361] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; } subgraph cluster922 { label="AQEShuffleRead"; 362 [labelType="html" label="ShuffledRowRDD [362] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; } subgraph cluster919 { label="WholeStageCodegen (2)"; 363 [labelType="html" label="MapPartitionsRDD [363] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; } subgraph cluster910 { label="WholeStageCodegen (3)"; 364 [labelType="html" label="ZippedPartitionsRDD2 [364] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; 365 [labelType="html" label="MapPartitionsRDD [365] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; } subgraph cluster909 { label="Exchange"; 366 [labelType="html" label="MapPartitionsRDD [366] [Unordered]<br>save at FileStorageAdapterImpl.java:755"]; } } 360->361; 362->363; 361->364; 363->364; 364->365; 365->366; }
353,360
356,362
Event Timeline
Enable zooming
Tasks: 1. 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