4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 599 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
95 ms
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 27
Shuffle Write Size / Records:
2037.0 B / 27
Associated Job Ids:
285
DAG Visualization
digraph G { id="graph_599"; subgraph graph_stage_599 { id="graph_stage_599"; isCluster="true"; label="Stage 599"; subgraph cluster_4853 { id="cluster_4853"; isCluster="true"; label="Scan parquet "; 1580 [id="node_1580" labelType="html" label="FileScanRDD [1580]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1581 [id="node_1581" labelType="html" label="MapPartitionsRDD [1581]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4841 { id="cluster_4841"; isCluster="true"; label="WholeStageCodegen (27)"; 1582 [id="node_1582" labelType="html" label="MapPartitionsRDD [1582]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4840 { id="cluster_4840"; isCluster="true"; label="Exchange"; 1584 [id="node_1584" labelType="html" label="MapPartitionsRDD [1584]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1585 [id="node_1585" labelType="html" label="MapPartitionsRDD [1585]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1580->1581; 1581->1582; 1582->1584; 1584->1585; }
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