4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1100 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 1518
Shuffle Write Size / Records:
264.3 KiB / 1518
Associated Job Ids:
518
DAG Visualization
digraph G { id="graph_1100"; subgraph graph_stage_1100 { id="graph_stage_1100"; isCluster="true"; label="Stage 1100"; subgraph cluster_8903 { id="cluster_8903"; isCluster="true"; label="Scan parquet "; 2898 [id="node_2898" labelType="html" label="FileScanRDD [2898]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 2899 [id="node_2899" labelType="html" label="MapPartitionsRDD [2899]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_8873 { id="cluster_8873"; isCluster="true"; label="WholeStageCodegen (6)"; 2903 [id="node_2903" labelType="html" label="MapPartitionsRDD [2903]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_8872 { id="cluster_8872"; isCluster="true"; label="Exchange"; 2904 [id="node_2904" labelType="html" label="MapPartitionsRDD [2904]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 2905 [id="node_2905" labelType="html" label="MapPartitionsRDD [2905]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 2898->2899; 2899->2903; 2903->2904; 2904->2905; }
Event Timeline
Enable zooming
Tasks: 1. 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