4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 278671 (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 / 1326
Shuffle Write Size / Records:
63.0 KiB / 1326
Associated Job Ids:
96720
DAG Visualization
digraph G { id="graph_278671"; subgraph graph_stage_278671 { id="graph_stage_278671"; isCluster="true"; label="Stage 278671"; subgraph cluster_1999310 { id="cluster_1999310"; isCluster="true"; label="Scan parquet "; 789725 [id="node_789725" labelType="html" label="FileScanRDD [789725]<br>start at FileStorageAdapterImpl.java:174}"]; 789726 [id="node_789726" labelType="html" label="MapPartitionsRDD [789726]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999291 { id="cluster_1999291"; isCluster="true"; label="WholeStageCodegen (5)"; 789727 [id="node_789727" labelType="html" label="MapPartitionsRDD [789727]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999290 { id="cluster_1999290"; isCluster="true"; label="Exchange"; 789728 [id="node_789728" labelType="html" label="MapPartitionsRDD [789728]<br>start at FileStorageAdapterImpl.java:174}"]; } } 789725->789726; 789726->789727; 789727->789728; }
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