4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 604 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.7 s
Locality Level Summary:
Process local: 10
Input Size / Records:
0.0 B / 195
Shuffle Write Size / Records:
9.1 KiB / 195
Associated Job Ids:
290
DAG Visualization
digraph G { id="graph_604"; subgraph graph_stage_604 { id="graph_stage_604"; isCluster="true"; label="Stage 604"; subgraph cluster_4909 { id="cluster_4909"; isCluster="true"; label="Scan parquet "; 1605 [id="node_1605" labelType="html" label="FileScanRDD [1605]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; 1606 [id="node_1606" labelType="html" label="MapPartitionsRDD [1606]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4892 { id="cluster_4892"; isCluster="true"; label="WholeStageCodegen (5)"; 1607 [id="node_1607" labelType="html" label="MapPartitionsRDD [1607]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_4891 { id="cluster_4891"; isCluster="true"; label="Exchange"; 1608 [id="node_1608" labelType="html" label="MapPartitionsRDD [1608]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 1605->1606; 1606->1607; 1607->1608; }
Event Timeline
Enable zooming
Tasks: 10. 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