4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445589 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 63
Shuffle Write Size / Records:
325.0 B / 1
Associated Job Ids:
154607
DAG Visualization
digraph G { id="graph_445589"; subgraph graph_stage_445589 { id="graph_stage_445589"; isCluster="true"; label="Stage 445589"; subgraph cluster_3147201 { id="cluster_3147201"; isCluster="true"; label="Scan parquet "; 1241625 [id="node_1241625" labelType="html" label="FileScanRDD [1241625]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241626 [id="node_1241626" labelType="html" label="MapPartitionsRDD [1241626]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147183 { id="cluster_3147183"; isCluster="true"; label="WholeStageCodegen (8)"; 1241630 [id="node_1241630" labelType="html" label="MapPartitionsRDD [1241630]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147182 { id="cluster_3147182"; isCluster="true"; label="Exchange"; 1241631 [id="node_1241631" labelType="html" label="MapPartitionsRDD [1241631]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241632 [id="node_1241632" labelType="html" label="MapPartitionsRDD [1241632]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1241625->1241626; 1241626->1241630; 1241630->1241631; 1241631->1241632; }
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