4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190868 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 11
Input Size / Records:
0.0 B / 612
Shuffle Write Size / Records:
173.1 KiB / 612
Associated Job Ids:
52717
DAG Visualization
digraph G { id="graph_190868"; subgraph graph_stage_190868 { id="graph_stage_190868"; isCluster="true"; label="Stage 190868"; subgraph cluster_1111262 { id="cluster_1111262"; isCluster="true"; label="Scan parquet "; 425215 [id="node_425215" labelType="html" label="FileScanRDD [425215]<br>start at FileStorageAdapterImpl.java:179}"]; 425216 [id="node_425216" labelType="html" label="MapPartitionsRDD [425216]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111258 { id="cluster_1111258"; isCluster="true"; label="WholeStageCodegen (1)"; 425217 [id="node_425217" labelType="html" label="MapPartitionsRDD [425217]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111266 { id="cluster_1111266"; isCluster="true"; label="Scan json "; 425218 [id="node_425218" labelType="html" label="FileScanRDD [425218]<br>start at FileStorageAdapterImpl.java:179}"]; 425219 [id="node_425219" labelType="html" label="MapPartitionsRDD [425219]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111263 { id="cluster_1111263"; isCluster="true"; label="WholeStageCodegen (2)"; 425220 [id="node_425220" labelType="html" label="MapPartitionsRDD [425220]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111257 { id="cluster_1111257"; isCluster="true"; label="Union"; 425221 [id="node_425221" labelType="html" label="UnionRDD [425221]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111256 { id="cluster_1111256"; isCluster="true"; label="Exchange"; 425222 [id="node_425222" labelType="html" label="MapPartitionsRDD [425222]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425215->425216; 425216->425217; 425218->425219; 425219->425220; 425217->425221; 425220->425221; 425221->425222; }
Event Timeline
Enable zooming
Tasks: 11. 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