4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445560 (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 / 63
Shuffle Write Size / Records:
75.0 B / 1
Associated Job Ids:
154586
DAG Visualization
digraph G { id="graph_445560"; subgraph graph_stage_445560 { id="graph_stage_445560"; isCluster="true"; label="Stage 445560"; subgraph cluster_3146989 { id="cluster_3146989"; isCluster="true"; label="Scan parquet "; 1241553 [id="node_1241553" labelType="html" label="FileScanRDD [1241553]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241554 [id="node_1241554" labelType="html" label="MapPartitionsRDD [1241554]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146984 { id="cluster_3146984"; isCluster="true"; label="WholeStageCodegen (1)"; 1241555 [id="node_1241555" labelType="html" label="MapPartitionsRDD [1241555]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_3146983 { id="cluster_3146983"; isCluster="true"; label="Exchange"; 1241556 [id="node_1241556" labelType="html" label="MapPartitionsRDD [1241556]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1241557 [id="node_1241557" labelType="html" label="MapPartitionsRDD [1241557]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1241553->1241554; 1241554->1241555; 1241555->1241556; 1241556->1241557; }
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