4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69368 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 21
Input Size / Records:
0.0 B / 1593
Shuffle Write Size / Records:
165.3 KiB / 1593
Associated Job Ids:
25739
DAG Visualization
digraph G { id="graph_69368"; subgraph graph_stage_69368 { id="graph_stage_69368"; isCluster="true"; label="Stage 69368"; subgraph cluster_515095 { id="cluster_515095"; isCluster="true"; label="Scan parquet "; 195510 [id="node_195510" labelType="html" label="FileScanRDD [195510]<br>start at FileStorageAdapterImpl.java:179}"]; 195511 [id="node_195511" labelType="html" label="MapPartitionsRDD [195511]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515079 { id="cluster_515079"; isCluster="true"; label="WholeStageCodegen (2)"; 195512 [id="node_195512" labelType="html" label="MapPartitionsRDD [195512]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515078 { id="cluster_515078"; isCluster="true"; label="Exchange"; 195513 [id="node_195513" labelType="html" label="MapPartitionsRDD [195513]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195510->195511; 195511->195512; 195512->195513; }
Event Timeline
Enable zooming
Tasks: 21. 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