4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99927 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 7
Input Size / Records:
0.0 B / 134
Shuffle Write Size / Records:
10.2 KiB / 134
Associated Job Ids:
5278
DAG Visualization
digraph G { id="graph_99927"; subgraph graph_stage_99927 { id="graph_stage_99927"; isCluster="true"; label="Stage 99927"; 46342 [id="node_46342" labelType="html" label="SQLExecutionRDD [46342]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_120373 { id="cluster_120373"; isCluster="true"; label="Scan parquet "; 46339 [id="node_46339" labelType="html" label="FileScanRDD [46339]<br>start at FileStorageAdapterImpl.java:171}"]; 46340 [id="node_46340" labelType="html" label="MapPartitionsRDD [46340]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120370 { id="cluster_120370"; isCluster="true"; label="WholeStageCodegen (1)"; 46341 [id="node_46341" labelType="html" label="MapPartitionsRDD [46341]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120377 { id="cluster_120377"; isCluster="true"; label="WholeStageCodegen (1)"; 46343 [id="node_46343" labelType="html" label="MapPartitionsRDD [46343]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_120376 { id="cluster_120376"; isCluster="true"; label="Exchange"; 46344 [id="node_46344" labelType="html" label="MapPartitionsRDD [46344]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46339->46340; 46340->46341; 46341->46342; 46342->46343; 46343->46344; }
Event Timeline
Enable zooming
Tasks: 7. 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