4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190885 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2.5 min
Locality Level Summary:
Any: 10; Node local: 20
Shuffle Read Size / Records:
20.3 MiB / 222552
Associated Job Ids:
52720
DAG Visualization
digraph G { id="graph_190885"; subgraph graph_stage_190885 { id="graph_stage_190885"; isCluster="true"; label="Stage 190885"; 425319 [id="node_425319" labelType="html" label="SQLExecutionRDD [425319] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1111295 { id="cluster_1111295"; isCluster="true"; label="Exchange"; 425297 [id="node_425297" labelType="html" label="ShuffledRowRDD [425297] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111292 { id="cluster_1111292"; isCluster="true"; label="WholeStageCodegen (19)"; 425298 [id="node_425298" labelType="html" label="MapPartitionsRDD [425298] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111417 { id="cluster_1111417"; isCluster="true"; label="Exchange"; 425311 [id="node_425311" labelType="html" label="ShuffledRowRDD [425311] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111414 { id="cluster_1111414"; isCluster="true"; label="WholeStageCodegen (22)"; 425312 [id="node_425312" labelType="html" label="MapPartitionsRDD [425312] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111287 { id="cluster_1111287"; isCluster="true"; label="WholeStageCodegen (23)"; 425313 [id="node_425313" labelType="html" label="ZippedPartitionsRDD2 [425313] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 425314 [id="node_425314" labelType="html" label="MapPartitionsRDD [425314] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111286 { id="cluster_1111286"; isCluster="true"; label="DeserializeToObject"; 425315 [id="node_425315" labelType="html" label="MapPartitionsRDD [425315] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111285 { id="cluster_1111285"; isCluster="true"; label="MapPartitions"; 425316 [id="node_425316" labelType="html" label="MapPartitionsRDD [425316] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111234 { id="cluster_1111234"; isCluster="true"; label="WholeStageCodegen (26)"; 425317 [id="node_425317" labelType="html" label="MapPartitionsRDD [425317] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111233 { id="cluster_1111233"; isCluster="true"; label="DeserializeToObject"; 425318 [id="node_425318" labelType="html" label="MapPartitionsRDD [425318] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111430 { id="cluster_1111430"; isCluster="true"; label="mapPartitions"; 425320 [id="node_425320" labelType="html" label="MapPartitionsRDD [425320] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111431 { id="cluster_1111431"; isCluster="true"; label="mapPartitions"; 425321 [id="node_425321" labelType="html" label="MapPartitionsRDD [425321] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425297->425298; 425311->425312; 425298->425313; 425312->425313; 425313->425314; 425314->425315; 425315->425316; 425316->425317; 425317->425318; 425318->425319; 425319->425320; 425320->425321; }
425296,425297
425310,425311
425321
Event Timeline
Enable zooming
Tasks: 30. 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