4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1031246 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.2 s
Locality Level Summary:
Process local: 50
Input Size / Records:
217.4 KiB / 1789
Associated Job Ids:
52656
DAG Visualization
digraph G { id="graph_1031246"; subgraph graph_stage_1031246 { id="graph_stage_1031246"; isCluster="true"; label="Stage 1031246"; 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_1087221 { id="cluster_1087221"; isCluster="true"; label="WholeStageCodegen (1)"; 433937 [id="node_433937" labelType="html" label="MapPartitionsRDD [433937] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1087225 { id="cluster_1087225"; isCluster="true"; label="mapPartitionsInternal"; 433938 [id="node_433938" labelType="html" label="MapPartitionsRDD [433938] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 433918->433919; 433919->433920; 433920->433921; 433921->433922; 433922->433923; 433923->433924; 433924->433937; 433937->433938; }
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