4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 191143 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
17 s
Locality Level Summary:
Node local: 50
Shuffle Read Size / Records:
170.8 KiB / 612
Shuffle Write Size / Records:
6.0 KiB / 50
Associated Job Ids:
52771
DAG Visualization
digraph G { id="graph_191143"; subgraph graph_stage_191143 { id="graph_stage_191143"; isCluster="true"; label="Stage 191143"; 425966 [id="node_425966" labelType="html" label="SQLExecutionRDD [425966] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1113091 { id="cluster_1113091"; isCluster="true"; label="Exchange"; 425961 [id="node_425961" labelType="html" label="ShuffledRowRDD [425961] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113087 { id="cluster_1113087"; isCluster="true"; label="WholeStageCodegen (3)"; 425962 [id="node_425962" labelType="html" label="MapPartitionsRDD [425962] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113086 { id="cluster_1113086"; isCluster="true"; label="DeserializeToObject"; 425963 [id="node_425963" labelType="html" label="MapPartitionsRDD [425963] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113085 { id="cluster_1113085"; isCluster="true"; label="MapPartitions"; 425964 [id="node_425964" labelType="html" label="MapPartitionsRDD [425964] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113082 { id="cluster_1113082"; isCluster="true"; label="WholeStageCodegen (4)"; 425965 [id="node_425965" labelType="html" label="MapPartitionsRDD [425965] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113102 { id="cluster_1113102"; isCluster="true"; label="map"; 425967 [id="node_425967" labelType="html" label="Delta Table State #20 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000532/stream-10000000532-1/_delta_log [425967] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113106 { id="cluster_1113106"; isCluster="true"; label="WholeStageCodegen (1)"; 425968 [id="node_425968" labelType="html" label="MapPartitionsRDD [425968] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113105 { id="cluster_1113105"; isCluster="true"; label="ObjectHashAggregate"; 425969 [id="node_425969" labelType="html" label="MapPartitionsRDD [425969] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113104 { id="cluster_1113104"; isCluster="true"; label="Exchange"; 425970 [id="node_425970" labelType="html" label="MapPartitionsRDD [425970] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425961->425962; 425962->425963; 425963->425964; 425964->425965; 425965->425966; 425966->425967; 425967->425968; 425968->425969; 425969->425970; }
425960,425961
425967
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