4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 603 (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 / 150
Shuffle Write Size / Records:
19.4 KiB / 150
Associated Job Ids:
289
DAG Visualization
digraph G { id="graph_603"; subgraph graph_stage_603 { id="graph_stage_603"; isCluster="true"; label="Stage 603"; subgraph cluster_4897 { id="cluster_4897"; isCluster="true"; label="Scan parquet "; 1600 [id="node_1600" labelType="html" label="FileScanRDD [1600]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1601 [id="node_1601" labelType="html" label="MapPartitionsRDD [1601]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4884 { id="cluster_4884"; isCluster="true"; label="WholeStageCodegen (4)"; 1602 [id="node_1602" labelType="html" label="MapPartitionsRDD [1602]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4883 { id="cluster_4883"; isCluster="true"; label="Exchange"; 1603 [id="node_1603" labelType="html" label="MapPartitionsRDD [1603]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1604 [id="node_1604" labelType="html" label="MapPartitionsRDD [1604]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1600->1601; 1601->1602; 1602->1603; 1603->1604; }
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