4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 112296 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 1
Input Size / Records:
0.0 B / 2
Shuffle Write Size / Records:
210.0 B / 2
Associated Job Ids:
6127
DAG Visualization
digraph G { id="graph_112296"; subgraph graph_stage_112296 { id="graph_stage_112296"; isCluster="true"; label="Stage 112296"; 53719 [id="node_53719" labelType="html" label="SQLExecutionRDD [53719]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_139729 { id="cluster_139729"; isCluster="true"; label="Scan parquet "; 53716 [id="node_53716" labelType="html" label="FileScanRDD [53716]<br>start at FileStorageAdapterImpl.java:171}"]; 53717 [id="node_53717" labelType="html" label="MapPartitionsRDD [53717]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139726 { id="cluster_139726"; isCluster="true"; label="WholeStageCodegen (1)"; 53718 [id="node_53718" labelType="html" label="MapPartitionsRDD [53718]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139733 { id="cluster_139733"; isCluster="true"; label="WholeStageCodegen (1)"; 53720 [id="node_53720" labelType="html" label="MapPartitionsRDD [53720]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139732 { id="cluster_139732"; isCluster="true"; label="Exchange"; 53721 [id="node_53721" labelType="html" label="MapPartitionsRDD [53721]<br>start at FileStorageAdapterImpl.java:171}"]; } } 53716->53717; 53717->53718; 53718->53719; 53719->53720; 53720->53721; }
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