4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446402 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 23
Input Size / Records:
0.0 B / 64
Shuffle Write Size / Records:
11.7 KiB / 64
Associated Job Ids:
154891
DAG Visualization
digraph G { id="graph_446402"; subgraph graph_stage_446402 { id="graph_stage_446402"; isCluster="true"; label="Stage 446402"; 1243756 [id="node_1243756" labelType="html" label="SQLExecutionRDD [1243756]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3152997 { id="cluster_3152997"; isCluster="true"; label="Scan parquet "; 1243753 [id="node_1243753" labelType="html" label="FileScanRDD [1243753]<br>start at FileStorageAdapterImpl.java:174}"]; 1243754 [id="node_1243754" labelType="html" label="MapPartitionsRDD [1243754]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152994 { id="cluster_3152994"; isCluster="true"; label="WholeStageCodegen (1)"; 1243755 [id="node_1243755" labelType="html" label="MapPartitionsRDD [1243755]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153001 { id="cluster_3153001"; isCluster="true"; label="WholeStageCodegen (1)"; 1243757 [id="node_1243757" labelType="html" label="MapPartitionsRDD [1243757]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3153000 { id="cluster_3153000"; isCluster="true"; label="Exchange"; 1243758 [id="node_1243758" labelType="html" label="MapPartitionsRDD [1243758]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1243753->1243754; 1243754->1243755; 1243755->1243756; 1243756->1243757; 1243757->1243758; }
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