4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190887 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.5 s
Locality Level Summary:
Process local: 50
Input Size / Records:
85.0 KiB / 602
Shuffle Write Size / Records:
85.3 KiB / 602
Associated Job Ids:
52721
DAG Visualization
digraph G { id="graph_190887"; subgraph graph_stage_190887 { id="graph_stage_190887"; isCluster="true"; label="Stage 190887"; 425228 [id="node_425228" labelType="html" label="SQLExecutionRDD [425228] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1111256 { id="cluster_1111256"; isCluster="true"; label="Exchange"; 425223 [id="node_425223" labelType="html" label="ShuffledRowRDD [425223] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111252 { id="cluster_1111252"; isCluster="true"; label="WholeStageCodegen (3)"; 425224 [id="node_425224" labelType="html" label="MapPartitionsRDD [425224] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111251 { id="cluster_1111251"; isCluster="true"; label="DeserializeToObject"; 425225 [id="node_425225" labelType="html" label="MapPartitionsRDD [425225] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111250 { id="cluster_1111250"; isCluster="true"; label="MapPartitions"; 425226 [id="node_425226" labelType="html" label="MapPartitionsRDD [425226] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111246 { id="cluster_1111246"; isCluster="true"; label="WholeStageCodegen (4)"; 425227 [id="node_425227" labelType="html" label="MapPartitionsRDD [425227] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111267 { id="cluster_1111267"; isCluster="true"; label="map"; 425229 [id="node_425229" 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-3/_delta_log [425229] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111460 { id="cluster_1111460"; isCluster="true"; label="WholeStageCodegen (1)"; 425322 [id="node_425322" labelType="html" label="MapPartitionsRDD [425322] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1111459 { id="cluster_1111459"; isCluster="true"; label="Exchange"; 425323 [id="node_425323" labelType="html" label="MapPartitionsRDD [425323] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425223->425224; 425224->425225; 425225->425226; 425226->425227; 425227->425228; 425228->425229; 425229->425322; 425322->425323; }
425222,425223
425229
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