4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99254 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.3 s
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 144
Shuffle Write Size / Records:
28.2 KiB / 144
Associated Job Ids:
5206
DAG Visualization
digraph G { id="graph_99254"; subgraph graph_stage_99254 { id="graph_stage_99254"; isCluster="true"; label="Stage 99254"; subgraph cluster_118377 { id="cluster_118377"; isCluster="true"; label="Scan parquet "; 45500 [id="node_45500" labelType="html" label="FileScanRDD [45500]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 45501 [id="node_45501" labelType="html" label="MapPartitionsRDD [45501]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_118361 { id="cluster_118361"; isCluster="true"; label="WholeStageCodegen (3)"; 45505 [id="node_45505" labelType="html" label="MapPartitionsRDD [45505]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_118360 { id="cluster_118360"; isCluster="true"; label="Exchange"; 45506 [id="node_45506" labelType="html" label="MapPartitionsRDD [45506]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 45507 [id="node_45507" labelType="html" label="MapPartitionsRDD [45507]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 45500->45501; 45501->45505; 45505->45506; 45506->45507; }
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