4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 116510 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 30; Process local: 7
Shuffle Read Size / Records:
307.9 KiB / 146
Shuffle Write Size / Records:
302.0 KiB / 69
Associated Job Ids:
6407
DAG Visualization
digraph G { id="graph_116510"; subgraph graph_stage_116510 { id="graph_stage_116510"; isCluster="true"; label="Stage 116510"; subgraph cluster_146163 { id="cluster_146163"; isCluster="true"; label="Exchange"; 56274 [id="node_56274" labelType="html" label="ShuffledRowRDD [56274] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146160 { id="cluster_146160"; isCluster="true"; label="WholeStageCodegen (10)"; 56275 [id="node_56275" labelType="html" label="MapPartitionsRDD [56275] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146225 { id="cluster_146225"; isCluster="true"; label="Exchange"; 56290 [id="node_56290" labelType="html" label="ShuffledRowRDD [56290] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146222 { id="cluster_146222"; isCluster="true"; label="WholeStageCodegen (13)"; 56291 [id="node_56291" labelType="html" label="MapPartitionsRDD [56291] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146156 { id="cluster_146156"; isCluster="true"; label="WholeStageCodegen (14)"; 56292 [id="node_56292" labelType="html" label="ZippedPartitionsRDD2 [56292] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; 56293 [id="node_56293" labelType="html" label="MapPartitionsRDD [56293] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146155 { id="cluster_146155"; isCluster="true"; label="ObjectHashAggregate"; 56294 [id="node_56294" labelType="html" label="MapPartitionsRDD [56294] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146154 { id="cluster_146154"; isCluster="true"; label="Exchange"; 56295 [id="node_56295" labelType="html" label="MapPartitionsRDD [56295] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56274->56275; 56290->56291; 56275->56292; 56291->56292; 56292->56293; 56293->56294; 56294->56295; }
56273,56274
56289,56290
56290
56291
56292
56293
56294
56295
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