4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 96771 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 1; Process local: 36
Shuffle Read Size / Records:
4.2 KiB / 2
Shuffle Write Size / Records:
4.1 KiB / 1
Associated Job Ids:
5036
DAG Visualization
digraph G { id="graph_96771"; subgraph graph_stage_96771 { id="graph_stage_96771"; isCluster="true"; label="Stage 96771"; subgraph cluster_115028 { id="cluster_115028"; isCluster="true"; label="Exchange"; 44285 [id="node_44285" labelType="html" label="ShuffledRowRDD [44285] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115025 { id="cluster_115025"; isCluster="true"; label="WholeStageCodegen (10)"; 44286 [id="node_44286" labelType="html" label="MapPartitionsRDD [44286] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115090 { id="cluster_115090"; isCluster="true"; label="Exchange"; 44301 [id="node_44301" labelType="html" label="ShuffledRowRDD [44301] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115087 { id="cluster_115087"; isCluster="true"; label="WholeStageCodegen (13)"; 44302 [id="node_44302" labelType="html" label="MapPartitionsRDD [44302] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115021 { id="cluster_115021"; isCluster="true"; label="WholeStageCodegen (14)"; 44303 [id="node_44303" labelType="html" label="ZippedPartitionsRDD2 [44303] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 44304 [id="node_44304" labelType="html" label="MapPartitionsRDD [44304] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115020 { id="cluster_115020"; isCluster="true"; label="ObjectHashAggregate"; 44305 [id="node_44305" labelType="html" label="MapPartitionsRDD [44305] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_115019 { id="cluster_115019"; isCluster="true"; label="Exchange"; 44306 [id="node_44306" labelType="html" label="MapPartitionsRDD [44306] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 44285->44286; 44301->44302; 44286->44303; 44302->44303; 44303->44304; 44304->44305; 44305->44306; }
44284,44285
44300,44301
44301
44302
44303
44304
44305
44306
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