4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446209 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 10; Process local: 10
Shuffle Read Size / Records:
12.0 KiB / 36
Shuffle Write Size / Records:
9.5 KiB / 15
Associated Job Ids:
154829
DAG Visualization
digraph G { id="graph_446209"; subgraph graph_stage_446209 { id="graph_stage_446209"; isCluster="true"; label="Stage 446209"; subgraph cluster_3151596 { id="cluster_3151596"; isCluster="true"; label="Exchange"; 1243190 [id="node_1243190" labelType="html" label="ShuffledRowRDD [1243190] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151593 { id="cluster_3151593"; isCluster="true"; label="WholeStageCodegen (6)"; 1243191 [id="node_1243191" labelType="html" label="MapPartitionsRDD [1243191] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151628 { id="cluster_3151628"; isCluster="true"; label="Exchange"; 1243201 [id="node_1243201" labelType="html" label="ShuffledRowRDD [1243201] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151625 { id="cluster_3151625"; isCluster="true"; label="WholeStageCodegen (12)"; 1243202 [id="node_1243202" labelType="html" label="MapPartitionsRDD [1243202] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151589 { id="cluster_3151589"; isCluster="true"; label="WholeStageCodegen (13)"; 1243203 [id="node_1243203" labelType="html" label="ZippedPartitionsRDD2 [1243203] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 1243204 [id="node_1243204" labelType="html" label="MapPartitionsRDD [1243204] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151588 { id="cluster_3151588"; isCluster="true"; label="ObjectHashAggregate"; 1243205 [id="node_1243205" labelType="html" label="MapPartitionsRDD [1243205] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3151587 { id="cluster_3151587"; isCluster="true"; label="Exchange"; 1243206 [id="node_1243206" labelType="html" label="MapPartitionsRDD [1243206] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1243190->1243191; 1243201->1243202; 1243191->1243203; 1243202->1243203; 1243203->1243204; 1243204->1243205; 1243205->1243206; }
1243189,1243190
1243200,1243201
Event Timeline
Enable zooming
Tasks: 20. 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