4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 99124 (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 / 1
Shuffle Write Size / Records:
62.0 B / 1
Associated Job Ids:
5143
DAG Visualization
digraph G { id="graph_99124"; subgraph graph_stage_99124 { id="graph_stage_99124"; isCluster="true"; label="Stage 99124"; subgraph cluster_117419 { id="cluster_117419"; isCluster="true"; label="Scan parquet "; 45239 [id="node_45239" labelType="html" label="FileScanRDD [45239]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 45240 [id="node_45240" labelType="html" label="MapPartitionsRDD [45240]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_117414 { id="cluster_117414"; isCluster="true"; label="WholeStageCodegen (1)"; 45241 [id="node_45241" labelType="html" label="MapPartitionsRDD [45241]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_117413 { id="cluster_117413"; isCluster="true"; label="Exchange"; 45242 [id="node_45242" labelType="html" label="MapPartitionsRDD [45242]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 45243 [id="node_45243" labelType="html" label="MapPartitionsRDD [45243]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 45239->45240; 45240->45241; 45241->45242; 45242->45243; }
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