4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69459 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
13 s
Locality Level Summary:
Node local: 30
Shuffle Read Size / Records:
366.3 KiB / 700
Associated Job Ids:
25769
DAG Visualization
digraph G { id="graph_69459"; subgraph graph_stage_69459 { id="graph_stage_69459"; isCluster="true"; label="Stage 69459"; 195795 [id="node_195795" labelType="html" label="SQLExecutionRDD [195795] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_515720 { id="cluster_515720"; isCluster="true"; label="Exchange"; 195787 [id="node_195787" labelType="html" label="ShuffledRowRDD [195787] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515719 { id="cluster_515719"; isCluster="true"; label="ObjectHashAggregate"; 195788 [id="node_195788" labelType="html" label="MapPartitionsRDD [195788] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515718 { id="cluster_515718"; isCluster="true"; label="Project"; 195789 [id="node_195789" labelType="html" label="MapPartitionsRDD [195789] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515711 { id="cluster_515711"; isCluster="true"; label="WholeStageCodegen (16)"; 195790 [id="node_195790" labelType="html" label="MapPartitionsRDD [195790] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515710 { id="cluster_515710"; isCluster="true"; label="DeserializeToObject"; 195791 [id="node_195791" labelType="html" label="MapPartitionsRDD [195791] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515709 { id="cluster_515709"; isCluster="true"; label="MapPartitions"; 195792 [id="node_195792" labelType="html" label="MapPartitionsRDD [195792] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515641 { id="cluster_515641"; isCluster="true"; label="WholeStageCodegen (19)"; 195793 [id="node_195793" labelType="html" label="MapPartitionsRDD [195793] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515620 { id="cluster_515620"; isCluster="true"; label="DeserializeToObject"; 195794 [id="node_195794" labelType="html" label="MapPartitionsRDD [195794] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515797 { id="cluster_515797"; isCluster="true"; label="mapPartitions"; 195796 [id="node_195796" labelType="html" label="MapPartitionsRDD [195796] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515798 { id="cluster_515798"; isCluster="true"; label="mapPartitions"; 195797 [id="node_195797" labelType="html" label="MapPartitionsRDD [195797] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 195787->195788; 195788->195789; 195789->195790; 195790->195791; 195791->195792; 195792->195793; 195793->195794; 195794->195795; 195795->195796; 195796->195797; }
195786,195787
195797
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