4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1654506 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
9 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
2.6 MiB / 11440
Shuffle Write Size / Records:
1935.5 KiB / 4715
Associated Job Ids:
86005
DAG Visualization
digraph G { id="graph_1654506"; subgraph graph_stage_1654506 { id="graph_stage_1654506"; isCluster="true"; label="Stage 1654506"; 709097 [id="node_709097" labelType="html" label="SQLExecutionRDD [709097] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1777781 { id="cluster_1777781"; isCluster="true"; label="Exchange"; 709081 [id="node_709081" labelType="html" label="ShuffledRowRDD [709081] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777778 { id="cluster_1777778"; isCluster="true"; label="WholeStageCodegen (3)"; 709082 [id="node_709082" labelType="html" label="MapPartitionsRDD [709082] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777796 { id="cluster_1777796"; isCluster="true"; label="Exchange"; 709092 [id="node_709092" labelType="html" label="ShuffledRowRDD [709092] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777793 { id="cluster_1777793"; isCluster="true"; label="WholeStageCodegen (8)"; 709093 [id="node_709093" labelType="html" label="MapPartitionsRDD [709093] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777774 { id="cluster_1777774"; isCluster="true"; label="WholeStageCodegen (9)"; 709094 [id="node_709094" labelType="html" label="ZippedPartitionsRDD2 [709094] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; 709095 [id="node_709095" labelType="html" label="MapPartitionsRDD [709095] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777773 { id="cluster_1777773"; isCluster="true"; label="DeserializeToObject"; 709096 [id="node_709096" labelType="html" label="MapPartitionsRDD [709096] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777816 { id="cluster_1777816"; isCluster="true"; label="mapPartitions"; 709098 [id="node_709098" labelType="html" label="MapPartitionsRDD [709098] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1777817 { id="cluster_1777817"; isCluster="true"; label="repartition"; 709099 [id="node_709099" labelType="html" label="MapPartitionsRDD [709099] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 709081->709082; 709092->709093; 709082->709094; 709093->709094; 709094->709095; 709095->709096; 709096->709097; 709097->709098; 709098->709099; }
709080,709081
709091,709092
709097
709081
709082
709092
709093
709094
709095
709096
709098
709099
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