4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 105946 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
10 s
Locality Level Summary:
Node local: 17; Process local: 20
Shuffle Read Size / Records:
91.8 KiB / 45
Associated Job Ids:
5922
DAG Visualization
digraph G { id="graph_105946"; subgraph graph_stage_105946 { id="graph_stage_105946"; isCluster="true"; label="Stage 105946"; 51196 [id="node_51196" labelType="html" label="SQLExecutionRDD [51196] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_133671 { id="cluster_133671"; isCluster="true"; label="Exchange"; 51191 [id="node_51191" labelType="html" label="ShuffledRowRDD [51191] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133670 { id="cluster_133670"; isCluster="true"; label="ObjectHashAggregate"; 51192 [id="node_51192" labelType="html" label="MapPartitionsRDD [51192] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133517 { id="cluster_133517"; isCluster="true"; label="WholeStageCodegen (17)"; 51193 [id="node_51193" labelType="html" label="MapPartitionsRDD [51193] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133516 { id="cluster_133516"; isCluster="true"; label="DeserializeToObject"; 51194 [id="node_51194" labelType="html" label="MapPartitionsRDD [51194] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133511 { id="cluster_133511"; isCluster="true"; label="MapPartitions"; 51195 [id="node_51195" labelType="html" label="MapPartitionsRDD [51195] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_133757 { id="cluster_133757"; isCluster="true"; label="mapPartitions"; 51197 [id="node_51197" labelType="html" label="MapPartitionsRDD [51197] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 51191->51192; 51192->51193; 51193->51194; 51194->51195; 51195->51196; 51196->51197; }
51190,51191
51197
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