4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 241123 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
54 s
Locality Level Summary:
Process local: 36
Input Size / Records:
0.0 B / 481520
Shuffle Write Size / Records:
19.6 MiB / 481520
Associated Job Ids:
66409
DAG Visualization
digraph G { id="graph_241123"; subgraph graph_stage_241123 { id="graph_stage_241123"; isCluster="true"; label="Stage 241123"; subgraph cluster_1409037 { id="cluster_1409037"; isCluster="true"; label="Scan parquet "; 539487 [id="node_539487" labelType="html" label="FileScanRDD [539487]<br>start at FileStorageAdapterImpl.java:179}"]; 539488 [id="node_539488" labelType="html" label="MapPartitionsRDD [539488]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409033 { id="cluster_1409033"; isCluster="true"; label="WholeStageCodegen (3)"; 539489 [id="node_539489" labelType="html" label="MapPartitionsRDD [539489]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1409032 { id="cluster_1409032"; isCluster="true"; label="Exchange"; 539490 [id="node_539490" labelType="html" label="MapPartitionsRDD [539490]<br>start at FileStorageAdapterImpl.java:179}"]; } } 539487->539488; 539488->539489; 539489->539490; }
Event Timeline
Enable zooming
Tasks: 36. 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