4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 2136598 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 50
Input Size / Records:
177.7 KiB / 1362
Associated Job Ids:
114684
DAG Visualization
digraph G { id="graph_2136598"; subgraph graph_stage_2136598 { id="graph_stage_2136598"; isCluster="true"; label="Stage 2136598"; 943527 [id="node_943527" labelType="html" label="SQLExecutionRDD [943527] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_2367105 { id="cluster_2367105"; isCluster="true"; label="Exchange"; 943522 [id="node_943522" labelType="html" label="ShuffledRowRDD [943522] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367101 { id="cluster_2367101"; isCluster="true"; label="WholeStageCodegen (3)"; 943523 [id="node_943523" labelType="html" label="MapPartitionsRDD [943523] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367100 { id="cluster_2367100"; isCluster="true"; label="DeserializeToObject"; 943524 [id="node_943524" labelType="html" label="MapPartitionsRDD [943524] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367099 { id="cluster_2367099"; isCluster="true"; label="MapPartitions"; 943525 [id="node_943525" labelType="html" label="MapPartitionsRDD [943525] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367096 { id="cluster_2367096"; isCluster="true"; label="WholeStageCodegen (4)"; 943526 [id="node_943526" labelType="html" label="MapPartitionsRDD [943526] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367116 { id="cluster_2367116"; isCluster="true"; label="map"; 943528 [id="node_943528" 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/optimal-quantities-cache/10000000553/_delta_log [943528] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367164 { id="cluster_2367164"; isCluster="true"; label="WholeStageCodegen (1)"; 943541 [id="node_943541" labelType="html" label="MapPartitionsRDD [943541] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_2367168 { id="cluster_2367168"; isCluster="true"; label="mapPartitionsInternal"; 943542 [id="node_943542" labelType="html" label="MapPartitionsRDD [943542] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 943522->943523; 943523->943524; 943524->943525; 943525->943526; 943526->943527; 943527->943528; 943528->943541; 943541->943542; }
943521,943522
943528
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