4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 337642 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.7 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
336.9 KiB / 0
Associated Job Ids:
18661
DAG Visualization
digraph G { id="graph_337642"; subgraph graph_stage_337642 { id="graph_stage_337642"; isCluster="true"; label="Stage 337642"; subgraph cluster_384281 { id="cluster_384281"; isCluster="true"; label="Exchange"; 153610 [id="node_153610" labelType="html" label="ShuffledRowRDD [153610] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384278 { id="cluster_384278"; isCluster="true"; label="WholeStageCodegen (2)"; 153611 [id="node_153611" labelType="html" label="MapPartitionsRDD [153611] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384292 { id="cluster_384292"; isCluster="true"; label="Exchange"; 153646 [id="node_153646" labelType="html" label="ShuffledRowRDD [153646] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384288 { id="cluster_384288"; isCluster="true"; label="WholeStageCodegen (6)"; 153647 [id="node_153647" labelType="html" label="MapPartitionsRDD [153647] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384265 { id="cluster_384265"; isCluster="true"; label="WholeStageCodegen (7)"; 153648 [id="node_153648" labelType="html" label="ZippedPartitionsRDD2 [153648] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153649 [id="node_153649" labelType="html" label="MapPartitionsRDD [153649] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_384264 { id="cluster_384264"; isCluster="true"; label="CollectLimit"; 153650 [id="node_153650" labelType="html" label="MapPartitionsRDD [153650] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 153651 [id="node_153651" labelType="html" label="MapPartitionsRDD [153651] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 153610->153611; 153646->153647; 153611->153648; 153647->153648; 153648->153649; 153649->153650; 153650->153651; }
153609,153610
153645,153646
153610
153611
153648
153649
153650
153651
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