4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1345361 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
50.6 KiB / 242
Associated Job Ids:
47348
DAG Visualization
digraph G { id="graph_1345361"; subgraph graph_stage_1345361 { id="graph_stage_1345361"; isCluster="true"; label="Stage 1345361"; 395168 [id="node_395168" labelType="html" label="SQLExecutionRDD [395168] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1040767 { id="cluster_1040767"; isCluster="true"; label="Exchange"; 395163 [id="node_395163" labelType="html" label="ShuffledRowRDD [395163] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040763 { id="cluster_1040763"; isCluster="true"; label="WholeStageCodegen (2)"; 395164 [id="node_395164" labelType="html" label="MapPartitionsRDD [395164] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040762 { id="cluster_1040762"; isCluster="true"; label="DeserializeToObject"; 395165 [id="node_395165" labelType="html" label="MapPartitionsRDD [395165] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040761 { id="cluster_1040761"; isCluster="true"; label="MapPartitions"; 395166 [id="node_395166" labelType="html" label="MapPartitionsRDD [395166] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040758 { id="cluster_1040758"; isCluster="true"; label="WholeStageCodegen (3)"; 395167 [id="node_395167" labelType="html" label="MapPartitionsRDD [395167] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040772 { id="cluster_1040772"; isCluster="true"; label="map"; 395169 [id="node_395169" labelType="html" label="Delta Table State #7 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000001445/_delta_log [395169] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040816 { id="cluster_1040816"; isCluster="true"; label="WholeStageCodegen (1)"; 395182 [id="node_395182" labelType="html" label="MapPartitionsRDD [395182] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1040820 { id="cluster_1040820"; isCluster="true"; label="mapPartitionsInternal"; 395183 [id="node_395183" labelType="html" label="MapPartitionsRDD [395183] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } } 395163->395164; 395164->395165; 395165->395166; 395166->395167; 395167->395168; 395168->395169; 395169->395182; 395182->395183; }
395162,395163
395169
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