4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1258 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.1 s
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 27
Shuffle Write Size / Records:
1705.0 B / 27
Associated Job Ids:
596
DAG Visualization
digraph G { id="graph_1258"; subgraph graph_stage_1258 { id="graph_stage_1258"; isCluster="true"; label="Stage 1258"; subgraph cluster_10445 { id="cluster_10445"; isCluster="true"; label="Scan parquet "; 3194 [id="node_3194" labelType="html" label="FileScanRDD [3194]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 3196 [id="node_3196" labelType="html" label="MapPartitionsRDD [3196]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10435 { id="cluster_10435"; isCluster="true"; label="WholeStageCodegen (3)"; 3199 [id="node_3199" labelType="html" label="MapPartitionsRDD [3199]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_10434 { id="cluster_10434"; isCluster="true"; label="Exchange"; 3202 [id="node_3202" labelType="html" label="MapPartitionsRDD [3202]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 3205 [id="node_3205" labelType="html" label="MapPartitionsRDD [3205]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 3194->3196; 3196->3199; 3199->3202; 3202->3205; }
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