4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 336897 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.8 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
107.0 KiB / 0
Associated Job Ids:
18627
DAG Visualization
digraph G { id="graph_336897"; subgraph graph_stage_336897 { id="graph_stage_336897"; isCluster="true"; label="Stage 336897"; subgraph cluster_383556 { id="cluster_383556"; isCluster="true"; label="Exchange"; 153338 [id="node_153338" labelType="html" label="ShuffledRowRDD [153338] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383553 { id="cluster_383553"; isCluster="true"; label="WholeStageCodegen (2)"; 153339 [id="node_153339" labelType="html" label="MapPartitionsRDD [153339] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383566 { id="cluster_383566"; isCluster="true"; label="Exchange"; 153347 [id="node_153347" labelType="html" label="ShuffledRowRDD [153347] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383562 { id="cluster_383562"; isCluster="true"; label="WholeStageCodegen (6)"; 153348 [id="node_153348" labelType="html" label="MapPartitionsRDD [153348] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383539 { id="cluster_383539"; isCluster="true"; label="WholeStageCodegen (7)"; 153349 [id="node_153349" labelType="html" label="ZippedPartitionsRDD2 [153349] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153350 [id="node_153350" labelType="html" label="MapPartitionsRDD [153350] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_383538 { id="cluster_383538"; isCluster="true"; label="CollectLimit"; 153351 [id="node_153351" labelType="html" label="MapPartitionsRDD [153351] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153352 [id="node_153352" labelType="html" label="MapPartitionsRDD [153352] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153338->153339; 153347->153348; 153339->153349; 153348->153349; 153349->153350; 153350->153351; 153351->153352; }
153337,153338
153346,153347
153338
153339
153349
153350
153351
153352
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