4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 330984 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
68 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
193.2 KiB / 1692
Associated Job Ids:
18456
DAG Visualization
digraph G { id="graph_330984"; subgraph graph_stage_330984 { id="graph_stage_330984"; isCluster="true"; label="Stage 330984"; 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_378831 { id="cluster_378831"; isCluster="true"; label="WholeStageCodegen (1)"; 151412 [id="node_151412" labelType="html" label="MapPartitionsRDD [151412] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_378835 { id="cluster_378835"; isCluster="true"; label="mapPartitionsInternal"; 151413 [id="node_151413" labelType="html" label="MapPartitionsRDD [151413] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 151360->151361; 151361->151362; 151362->151363; 151363->151364; 151364->151365; 151365->151366; 151366->151412; 151412->151413; }
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