4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 278713 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Process local: 23
Input Size / Records:
0.0 B / 158
Shuffle Write Size / Records:
21.6 KiB / 158
Associated Job Ids:
96732
DAG Visualization
digraph G { id="graph_278713"; subgraph graph_stage_278713 { id="graph_stage_278713"; isCluster="true"; label="Stage 278713"; 789849 [id="node_789849" labelType="html" label="SQLExecutionRDD [789849]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_1999655 { id="cluster_1999655"; isCluster="true"; label="Scan parquet "; 789846 [id="node_789846" labelType="html" label="FileScanRDD [789846]<br>start at FileStorageAdapterImpl.java:174}"]; 789847 [id="node_789847" labelType="html" label="MapPartitionsRDD [789847]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999652 { id="cluster_1999652"; isCluster="true"; label="WholeStageCodegen (1)"; 789848 [id="node_789848" labelType="html" label="MapPartitionsRDD [789848]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999659 { id="cluster_1999659"; isCluster="true"; label="WholeStageCodegen (1)"; 789850 [id="node_789850" labelType="html" label="MapPartitionsRDD [789850]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999658 { id="cluster_1999658"; isCluster="true"; label="Exchange"; 789851 [id="node_789851" labelType="html" label="MapPartitionsRDD [789851]<br>start at FileStorageAdapterImpl.java:174}"]; } } 789846->789847; 789847->789848; 789848->789849; 789849->789850; 789850->789851; }
Event Timeline
Enable zooming
Tasks: 23. 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