4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 330780 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Node local: 50
Shuffle Read Size / Records:
244.2 KiB / 1725
Shuffle Write Size / Records:
6.3 KiB / 50
Associated Job Ids:
18449
DAG Visualization
digraph G { id="graph_330780"; subgraph graph_stage_330780 { id="graph_stage_330780"; isCluster="true"; label="Stage 330780"; 151365 [id="node_151365" labelType="html" label="SQLExecutionRDD [151365] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_378722 { id="cluster_378722"; isCluster="true"; label="Exchange"; 151360 [id="node_151360" labelType="html" label="ShuffledRowRDD [151360] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378718 { id="cluster_378718"; isCluster="true"; label="WholeStageCodegen (3)"; 151361 [id="node_151361" labelType="html" label="MapPartitionsRDD [151361] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378717 { id="cluster_378717"; isCluster="true"; label="DeserializeToObject"; 151362 [id="node_151362" labelType="html" label="MapPartitionsRDD [151362] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378716 { id="cluster_378716"; isCluster="true"; label="MapPartitions"; 151363 [id="node_151363" labelType="html" label="MapPartitionsRDD [151363] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378713 { id="cluster_378713"; isCluster="true"; label="WholeStageCodegen (4)"; 151364 [id="node_151364" labelType="html" label="MapPartitionsRDD [151364] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378733 { id="cluster_378733"; isCluster="true"; label="map"; 151366 [id="node_151366" labelType="html" label="Delta Table State #53 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000000532/_delta_log [151366] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378737 { id="cluster_378737"; isCluster="true"; label="WholeStageCodegen (1)"; 151367 [id="node_151367" labelType="html" label="MapPartitionsRDD [151367] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378736 { id="cluster_378736"; isCluster="true"; label="ObjectHashAggregate"; 151368 [id="node_151368" labelType="html" label="MapPartitionsRDD [151368] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378735 { id="cluster_378735"; isCluster="true"; label="Exchange"; 151369 [id="node_151369" labelType="html" label="MapPartitionsRDD [151369] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 151360->151361; 151361->151362; 151362->151363; 151363->151364; 151364->151365; 151365->151366; 151366->151367; 151367->151368; 151368->151369; }
151359,151360
151366
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