4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446057 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
5 s
Locality Level Summary:
Node local: 7; Process local: 13
Shuffle Read Size / Records:
9.2 KiB / 15
Associated Job Ids:
154778
DAG Visualization
digraph G { id="graph_446057"; subgraph graph_stage_446057 { id="graph_stage_446057"; isCluster="true"; label="Stage 446057"; 1242766 [id="node_1242766" labelType="html" label="SQLExecutionRDD [1242766] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3150490 { id="cluster_3150490"; isCluster="true"; label="Exchange"; 1242758 [id="node_1242758" labelType="html" label="ShuffledRowRDD [1242758] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150489 { id="cluster_3150489"; isCluster="true"; label="ObjectHashAggregate"; 1242759 [id="node_1242759" labelType="html" label="MapPartitionsRDD [1242759] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150488 { id="cluster_3150488"; isCluster="true"; label="Project"; 1242760 [id="node_1242760" labelType="html" label="MapPartitionsRDD [1242760] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150467 { id="cluster_3150467"; isCluster="true"; label="WholeStageCodegen (16)"; 1242761 [id="node_1242761" labelType="html" label="MapPartitionsRDD [1242761] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150466 { id="cluster_3150466"; isCluster="true"; label="DeserializeToObject"; 1242762 [id="node_1242762" labelType="html" label="MapPartitionsRDD [1242762] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150465 { id="cluster_3150465"; isCluster="true"; label="MapPartitions"; 1242763 [id="node_1242763" labelType="html" label="MapPartitionsRDD [1242763] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150411 { id="cluster_3150411"; isCluster="true"; label="WholeStageCodegen (19)"; 1242764 [id="node_1242764" labelType="html" label="MapPartitionsRDD [1242764] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150390 { id="cluster_3150390"; isCluster="true"; label="DeserializeToObject"; 1242765 [id="node_1242765" labelType="html" label="MapPartitionsRDD [1242765] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150567 { id="cluster_3150567"; isCluster="true"; label="mapPartitions"; 1242767 [id="node_1242767" labelType="html" label="MapPartitionsRDD [1242767] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3150568 { id="cluster_3150568"; isCluster="true"; label="mapPartitions"; 1242768 [id="node_1242768" labelType="html" label="MapPartitionsRDD [1242768] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242758->1242759; 1242759->1242760; 1242760->1242761; 1242761->1242762; 1242762->1242763; 1242763->1242764; 1242764->1242765; 1242765->1242766; 1242766->1242767; 1242767->1242768; }
1242757,1242758
1242768
Event Timeline
Enable zooming
Tasks: 20. 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