4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446327 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 6
Input Size / Records:
0.0 B / 10
Shuffle Write Size / Records:
1589.0 B / 10
Associated Job Ids:
154866
DAG Visualization
digraph G { id="graph_446327"; subgraph graph_stage_446327 { id="graph_stage_446327"; isCluster="true"; label="Stage 446327"; 1243542 [id="node_1243542" labelType="html" label="SQLExecutionRDD [1243542]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3152473 { id="cluster_3152473"; isCluster="true"; label="Scan parquet "; 1243539 [id="node_1243539" labelType="html" label="FileScanRDD [1243539]<br>start at FileStorageAdapterImpl.java:174}"]; 1243540 [id="node_1243540" labelType="html" label="MapPartitionsRDD [1243540]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152470 { id="cluster_3152470"; isCluster="true"; label="WholeStageCodegen (1)"; 1243541 [id="node_1243541" labelType="html" label="MapPartitionsRDD [1243541]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152477 { id="cluster_3152477"; isCluster="true"; label="WholeStageCodegen (1)"; 1243543 [id="node_1243543" labelType="html" label="MapPartitionsRDD [1243543]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3152476 { id="cluster_3152476"; isCluster="true"; label="Exchange"; 1243544 [id="node_1243544" labelType="html" label="MapPartitionsRDD [1243544]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1243539->1243540; 1243540->1243541; 1243541->1243542; 1243542->1243543; 1243543->1243544; }
Event Timeline
Enable zooming
Tasks: 6. 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