4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 90852 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 9; Process local: 28
Shuffle Read Size / Records:
70.2 KiB / 17
Associated Job Ids:
4864
DAG Visualization
digraph G { id="graph_90852"; subgraph graph_stage_90852 { id="graph_stage_90852"; isCluster="true"; label="Stage 90852"; 42172 [id="node_42172" labelType="html" label="SQLExecutionRDD [42172] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_109981 { id="cluster_109981"; isCluster="true"; label="Exchange"; 42167 [id="node_42167" labelType="html" label="ShuffledRowRDD [42167] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109980 { id="cluster_109980"; isCluster="true"; label="ObjectHashAggregate"; 42168 [id="node_42168" labelType="html" label="MapPartitionsRDD [42168] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109830 { id="cluster_109830"; isCluster="true"; label="WholeStageCodegen (17)"; 42169 [id="node_42169" labelType="html" label="MapPartitionsRDD [42169] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109829 { id="cluster_109829"; isCluster="true"; label="DeserializeToObject"; 42170 [id="node_42170" labelType="html" label="MapPartitionsRDD [42170] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_109824 { id="cluster_109824"; isCluster="true"; label="MapPartitions"; 42171 [id="node_42171" labelType="html" label="MapPartitionsRDD [42171] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_110067 { id="cluster_110067"; isCluster="true"; label="mapPartitions"; 42173 [id="node_42173" labelType="html" label="MapPartitionsRDD [42173] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 42167->42168; 42168->42169; 42169->42170; 42170->42171; 42171->42172; 42172->42173; }
42166,42167
42173
42172
42167
42168
42169
42170
42171
42173
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