4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 101305 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 2
Input Size / Records:
0.0 B / 88
Shuffle Write Size / Records:
480.0 B / 1
Associated Job Ids:
5578
DAG Visualization
digraph G { id="graph_101305"; subgraph graph_stage_101305 { id="graph_stage_101305"; isCluster="true"; label="Stage 101305"; subgraph cluster_125654 { id="cluster_125654"; isCluster="true"; label="Scan parquet "; 48051 [id="node_48051" labelType="html" label="FileScanRDD [48051]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 48052 [id="node_48052" labelType="html" label="MapPartitionsRDD [48052]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125606 { id="cluster_125606"; isCluster="true"; label="WholeStageCodegen (8)"; 48053 [id="node_48053" labelType="html" label="MapPartitionsRDD [48053]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_125605 { id="cluster_125605"; isCluster="true"; label="Exchange"; 48055 [id="node_48055" labelType="html" label="MapPartitionsRDD [48055]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 48056 [id="node_48056" labelType="html" label="MapPartitionsRDD [48056]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 48051->48052; 48052->48053; 48053->48055; 48055->48056; }
Event Timeline
Enable zooming
Tasks: 2. 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