4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 104941 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
7 s
Locality Level Summary:
Node local: 19; Process local: 18
Shuffle Read Size / Records:
111.3 KiB / 56
Shuffle Write Size / Records:
109.8 KiB / 28
Associated Job Ids:
5780
DAG Visualization
digraph G { id="graph_104941"; subgraph graph_stage_104941 { id="graph_stage_104941"; isCluster="true"; label="Stage 104941"; subgraph cluster_131131 { id="cluster_131131"; isCluster="true"; label="Exchange"; 50322 [id="node_50322" labelType="html" label="ShuffledRowRDD [50322] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131128 { id="cluster_131128"; isCluster="true"; label="WholeStageCodegen (10)"; 50323 [id="node_50323" labelType="html" label="MapPartitionsRDD [50323] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131193 { id="cluster_131193"; isCluster="true"; label="Exchange"; 50338 [id="node_50338" labelType="html" label="ShuffledRowRDD [50338] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131190 { id="cluster_131190"; isCluster="true"; label="WholeStageCodegen (13)"; 50339 [id="node_50339" labelType="html" label="MapPartitionsRDD [50339] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131124 { id="cluster_131124"; isCluster="true"; label="WholeStageCodegen (14)"; 50340 [id="node_50340" labelType="html" label="ZippedPartitionsRDD2 [50340] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 50341 [id="node_50341" labelType="html" label="MapPartitionsRDD [50341] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131123 { id="cluster_131123"; isCluster="true"; label="ObjectHashAggregate"; 50342 [id="node_50342" labelType="html" label="MapPartitionsRDD [50342] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131122 { id="cluster_131122"; isCluster="true"; label="Exchange"; 50343 [id="node_50343" labelType="html" label="MapPartitionsRDD [50343] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 50322->50323; 50338->50339; 50323->50340; 50339->50340; 50340->50341; 50341->50342; 50342->50343; }
50321,50322
50337,50338
50338
50339
50340
50341
50342
50343
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