4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190065 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
22 s
Locality Level Summary:
Process local: 35
Input Size / Records:
0.0 B / 319744
Shuffle Write Size / Records:
8.5 MiB / 319744
Associated Job Ids:
52551
DAG Visualization
digraph G { id="graph_190065"; subgraph graph_stage_190065 { id="graph_stage_190065"; isCluster="true"; label="Stage 190065"; subgraph cluster_1106009 { id="cluster_1106009"; isCluster="true"; label="Scan parquet "; 423089 [id="node_423089" labelType="html" label="FileScanRDD [423089]<br>start at FileStorageAdapterImpl.java:179}"]; 423090 [id="node_423090" labelType="html" label="MapPartitionsRDD [423090]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106006 { id="cluster_1106006"; isCluster="true"; label="WholeStageCodegen (1)"; 423091 [id="node_423091" labelType="html" label="MapPartitionsRDD [423091]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106005 { id="cluster_1106005"; isCluster="true"; label="Exchange"; 423092 [id="node_423092" labelType="html" label="MapPartitionsRDD [423092]<br>start at FileStorageAdapterImpl.java:179}"]; } } 423089->423090; 423090->423091; 423091->423092; }
Event Timeline
Enable zooming
Tasks: 35. 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