4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445672 (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 / 6
Shuffle Write Size / Records:
3.7 KiB / 6
Associated Job Ids:
154644
DAG Visualization
digraph G { id="graph_445672"; subgraph graph_stage_445672 { id="graph_stage_445672"; isCluster="true"; label="Stage 445672"; subgraph cluster_3147727 { id="cluster_3147727"; isCluster="true"; label="Scan parquet "; 1241777 [id="node_1241777" labelType="html" label="FileScanRDD [1241777]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241778 [id="node_1241778" labelType="html" label="MapPartitionsRDD [1241778]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147720 { id="cluster_3147720"; isCluster="true"; label="WholeStageCodegen (81)"; 1241779 [id="node_1241779" labelType="html" label="MapPartitionsRDD [1241779]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3147719 { id="cluster_3147719"; isCluster="true"; label="Exchange"; 1241780 [id="node_1241780" labelType="html" label="MapPartitionsRDD [1241780]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241781 [id="node_1241781" labelType="html" label="MapPartitionsRDD [1241781]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1241777->1241778; 1241778->1241779; 1241779->1241780; 1241780->1241781; }
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