4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190869 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
4 s
Locality Level Summary:
Node local: 50
Shuffle Read Size / Records:
173.1 KiB / 612
Shuffle Write Size / Records:
6.0 KiB / 50
Associated Job Ids:
52717
DAG Visualization
digraph G { id="graph_190869"; subgraph graph_stage_190869 { id="graph_stage_190869"; isCluster="true"; label="Stage 190869"; 425228 [id="node_425228" labelType="html" label="SQLExecutionRDD [425228] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1111256 { id="cluster_1111256"; isCluster="true"; label="Exchange"; 425223 [id="node_425223" labelType="html" label="ShuffledRowRDD [425223] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111252 { id="cluster_1111252"; isCluster="true"; label="WholeStageCodegen (3)"; 425224 [id="node_425224" labelType="html" label="MapPartitionsRDD [425224] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111251 { id="cluster_1111251"; isCluster="true"; label="DeserializeToObject"; 425225 [id="node_425225" labelType="html" label="MapPartitionsRDD [425225] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111250 { id="cluster_1111250"; isCluster="true"; label="MapPartitions"; 425226 [id="node_425226" labelType="html" label="MapPartitionsRDD [425226] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111246 { id="cluster_1111246"; isCluster="true"; label="WholeStageCodegen (4)"; 425227 [id="node_425227" labelType="html" label="MapPartitionsRDD [425227] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111267 { id="cluster_1111267"; isCluster="true"; label="map"; 425229 [id="node_425229" labelType="html" label="Delta Table State #20 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000532/stream-10000000532-3/_delta_log [425229] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111271 { id="cluster_1111271"; isCluster="true"; label="WholeStageCodegen (1)"; 425230 [id="node_425230" labelType="html" label="MapPartitionsRDD [425230] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111270 { id="cluster_1111270"; isCluster="true"; label="ObjectHashAggregate"; 425231 [id="node_425231" labelType="html" label="MapPartitionsRDD [425231] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111269 { id="cluster_1111269"; isCluster="true"; label="Exchange"; 425232 [id="node_425232" labelType="html" label="MapPartitionsRDD [425232] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425223->425224; 425224->425225; 425225->425226; 425226->425227; 425227->425228; 425228->425229; 425229->425230; 425230->425231; 425231->425232; }
425222,425223
425229
Event Timeline
Enable zooming
Tasks: 50. 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