4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 241447 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2.2 min
Locality Level Summary:
Process local: 37
Input Size / Records:
0.0 B / 119954
Shuffle Write Size / Records:
5.4 MiB / 119954
Associated Job Ids:
66468
DAG Visualization
digraph G { id="graph_241447"; subgraph graph_stage_241447 { id="graph_stage_241447"; isCluster="true"; label="Stage 241447"; 540318 [id="node_540318" labelType="html" label="SQLExecutionRDD [540318]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1411113 { id="cluster_1411113"; isCluster="true"; label="Scan parquet "; 540315 [id="node_540315" labelType="html" label="FileScanRDD [540315]<br>start at FileStorageAdapterImpl.java:179}"]; 540316 [id="node_540316" labelType="html" label="MapPartitionsRDD [540316]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411110 { id="cluster_1411110"; isCluster="true"; label="WholeStageCodegen (1)"; 540317 [id="node_540317" labelType="html" label="MapPartitionsRDD [540317]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411117 { id="cluster_1411117"; isCluster="true"; label="WholeStageCodegen (1)"; 540319 [id="node_540319" labelType="html" label="MapPartitionsRDD [540319]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1411116 { id="cluster_1411116"; isCluster="true"; label="Exchange"; 540320 [id="node_540320" labelType="html" label="MapPartitionsRDD [540320]<br>start at FileStorageAdapterImpl.java:179}"]; } } 540315->540316; 540316->540317; 540317->540318; 540318->540319; 540319->540320; }
Event Timeline
Enable zooming
Tasks: 37. 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