4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 2136619 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 50
Shuffle Read Size / Records:
195.6 KiB / 1359
Shuffle Write Size / Records:
6.3 KiB / 50
Associated Job Ids:
114686
DAG Visualization
digraph G { id="graph_2136619"; subgraph graph_stage_2136619 { id="graph_stage_2136619"; isCluster="true"; label="Stage 2136619"; 943562 [id="node_943562" labelType="html" label="SQLExecutionRDD [943562] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_2367201 { id="cluster_2367201"; isCluster="true"; label="Exchange"; 943557 [id="node_943557" labelType="html" label="ShuffledRowRDD [943557] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367197 { id="cluster_2367197"; isCluster="true"; label="WholeStageCodegen (3)"; 943558 [id="node_943558" labelType="html" label="MapPartitionsRDD [943558] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367196 { id="cluster_2367196"; isCluster="true"; label="DeserializeToObject"; 943559 [id="node_943559" labelType="html" label="MapPartitionsRDD [943559] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367195 { id="cluster_2367195"; isCluster="true"; label="MapPartitions"; 943560 [id="node_943560" labelType="html" label="MapPartitionsRDD [943560] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367192 { id="cluster_2367192"; isCluster="true"; label="WholeStageCodegen (4)"; 943561 [id="node_943561" labelType="html" label="MapPartitionsRDD [943561] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367212 { id="cluster_2367212"; isCluster="true"; label="map"; 943563 [id="node_943563" labelType="html" label="Delta Table State #42 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000000553/_delta_log [943563] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367216 { id="cluster_2367216"; isCluster="true"; label="WholeStageCodegen (1)"; 943564 [id="node_943564" labelType="html" label="MapPartitionsRDD [943564] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367215 { id="cluster_2367215"; isCluster="true"; label="ObjectHashAggregate"; 943565 [id="node_943565" labelType="html" label="MapPartitionsRDD [943565] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367214 { id="cluster_2367214"; isCluster="true"; label="Exchange"; 943566 [id="node_943566" labelType="html" label="MapPartitionsRDD [943566] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 943557->943558; 943558->943559; 943559->943560; 943560->943561; 943561->943562; 943562->943563; 943563->943564; 943564->943565; 943565->943566; }
943556,943557
943563
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