4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 241478 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1.2 min
Locality Level Summary:
Process local: 35
Input Size / Records:
0.0 B / 1679356
Shuffle Write Size / Records:
53.8 MiB / 1679356
Associated Job Ids:
66479
DAG Visualization
digraph G { id="graph_241478"; subgraph graph_stage_241478 { id="graph_stage_241478"; isCluster="true"; label="Stage 241478"; subgraph cluster_1411419 { id="cluster_1411419"; isCluster="true"; label="Scan parquet "; 540434 [id="node_540434" labelType="html" label="FileScanRDD [540434]<br>start at FileStorageAdapterImpl.java:179}"]; 540435 [id="node_540435" labelType="html" label="MapPartitionsRDD [540435]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411415 { id="cluster_1411415"; isCluster="true"; label="WholeStageCodegen (12)"; 540436 [id="node_540436" labelType="html" label="MapPartitionsRDD [540436]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411414 { id="cluster_1411414"; isCluster="true"; label="Exchange"; 540437 [id="node_540437" labelType="html" label="MapPartitionsRDD [540437]<br>start at FileStorageAdapterImpl.java:179}"]; } } 540434->540435; 540435->540436; 540436->540437; }
Event Timeline
Enable zooming
Tasks: 35. 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