4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1031219 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 50
Shuffle Read Size / Records:
285.1 KiB / 1795
Shuffle Write Size / Records:
6.3 KiB / 50
Associated Job Ids:
52653
DAG Visualization
digraph G { id="graph_1031219"; subgraph graph_stage_1031219 { id="graph_stage_1031219"; isCluster="true"; label="Stage 1031219"; 433923 [id="node_433923" labelType="html" label="SQLExecutionRDD [433923] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1087162 { id="cluster_1087162"; isCluster="true"; label="Exchange"; 433918 [id="node_433918" labelType="html" label="ShuffledRowRDD [433918] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087158 { id="cluster_1087158"; isCluster="true"; label="WholeStageCodegen (3)"; 433919 [id="node_433919" labelType="html" label="MapPartitionsRDD [433919] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087157 { id="cluster_1087157"; isCluster="true"; label="DeserializeToObject"; 433920 [id="node_433920" labelType="html" label="MapPartitionsRDD [433920] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087156 { id="cluster_1087156"; isCluster="true"; label="MapPartitions"; 433921 [id="node_433921" labelType="html" label="MapPartitionsRDD [433921] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087153 { id="cluster_1087153"; isCluster="true"; label="WholeStageCodegen (4)"; 433922 [id="node_433922" labelType="html" label="MapPartitionsRDD [433922] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087173 { id="cluster_1087173"; isCluster="true"; label="map"; 433924 [id="node_433924" labelType="html" label="Delta Table State #56 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000000540/_delta_log [433924] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087177 { id="cluster_1087177"; isCluster="true"; label="WholeStageCodegen (1)"; 433925 [id="node_433925" labelType="html" label="MapPartitionsRDD [433925] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087176 { id="cluster_1087176"; isCluster="true"; label="ObjectHashAggregate"; 433926 [id="node_433926" labelType="html" label="MapPartitionsRDD [433926] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087175 { id="cluster_1087175"; isCluster="true"; label="Exchange"; 433927 [id="node_433927" labelType="html" label="MapPartitionsRDD [433927] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 433918->433919; 433919->433920; 433920->433921; 433921->433922; 433922->433923; 433923->433924; 433924->433925; 433925->433926; 433926->433927; }
433917,433918
433924
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