4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 241362 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Process local: 50
Input Size / Records:
12.0 KiB / 37
Associated Job Ids:
66452
DAG Visualization
digraph G { id="graph_241362"; subgraph graph_stage_241362 { id="graph_stage_241362"; isCluster="true"; label="Stage 241362"; 526340 [id="node_526340" labelType="html" label="SQLExecutionRDD [526340] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 526344 [id="node_526344" labelType="html" label="SQLExecutionRDD [526344] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1376764 { id="cluster_1376764"; isCluster="true"; label="Exchange"; 526335 [id="node_526335" labelType="html" label="ShuffledRowRDD [526335] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376760 { id="cluster_1376760"; isCluster="true"; label="WholeStageCodegen (2)"; 526336 [id="node_526336" labelType="html" label="MapPartitionsRDD [526336] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376759 { id="cluster_1376759"; isCluster="true"; label="DeserializeToObject"; 526337 [id="node_526337" labelType="html" label="MapPartitionsRDD [526337] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376758 { id="cluster_1376758"; isCluster="true"; label="MapPartitions"; 526338 [id="node_526338" labelType="html" label="MapPartitionsRDD [526338] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376755 { id="cluster_1376755"; isCluster="true"; label="WholeStageCodegen (3)"; 526339 [id="node_526339" labelType="html" label="MapPartitionsRDD [526339] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376769 { id="cluster_1376769"; isCluster="true"; label="map"; 526341 [id="node_526341" labelType="html" label="Delta Table State #1 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000540/0_4_10000000540/_delta_log [526341] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376771 { id="cluster_1376771"; isCluster="true"; label="WholeStageCodegen (1)"; 526342 [id="node_526342" labelType="html" label="MapPartitionsRDD [526342] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376770 { id="cluster_1376770"; isCluster="true"; label="Project"; 526343 [id="node_526343" labelType="html" label="MapPartitionsRDD [526343] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1376774 { id="cluster_1376774"; isCluster="true"; label="map"; 526345 [id="node_526345" labelType="html" label="Delta Table State with Stats #1 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000540/0_4_10000000540/_delta_log [526345] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410538 { id="cluster_1410538"; isCluster="true"; label="WholeStageCodegen (1)"; 540091 [id="node_540091" labelType="html" label="MapPartitionsRDD [540091] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1410542 { id="cluster_1410542"; isCluster="true"; label="mapPartitionsInternal"; 540092 [id="node_540092" labelType="html" label="MapPartitionsRDD [540092] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 526335->526336; 526336->526337; 526337->526338; 526338->526339; 526339->526340; 526340->526341; 526341->526342; 526342->526343; 526343->526344; 526344->526345; 526345->540091; 540091->540092; }
526334,526335
526341
526345
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