4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 446548 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.3 s
Locality Level Summary:
Process local: 50
Input Size / Records:
31.3 KiB / 142
Shuffle Write Size / Records:
31.5 KiB / 142
Associated Job Ids:
154938
DAG Visualization
digraph G { id="graph_446548"; subgraph graph_stage_446548 { id="graph_stage_446548"; isCluster="true"; label="Stage 446548"; 1244188 [id="node_1244188" labelType="html" label="SQLExecutionRDD [1244188] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3154038 { id="cluster_3154038"; isCluster="true"; label="Exchange"; 1244183 [id="node_1244183" labelType="html" label="ShuffledRowRDD [1244183] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154034 { id="cluster_3154034"; isCluster="true"; label="WholeStageCodegen (2)"; 1244184 [id="node_1244184" labelType="html" label="MapPartitionsRDD [1244184] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154033 { id="cluster_3154033"; isCluster="true"; label="DeserializeToObject"; 1244185 [id="node_1244185" labelType="html" label="MapPartitionsRDD [1244185] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154032 { id="cluster_3154032"; isCluster="true"; label="MapPartitions"; 1244186 [id="node_1244186" labelType="html" label="MapPartitionsRDD [1244186] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154029 { id="cluster_3154029"; isCluster="true"; label="WholeStageCodegen (3)"; 1244187 [id="node_1244187" labelType="html" label="MapPartitionsRDD [1244187] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154043 { id="cluster_3154043"; isCluster="true"; label="map"; 1244189 [id="node_1244189" labelType="html" label="Delta Table State #10 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000001651/stream-10000001651-1/_delta_log [1244189] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154076 { id="cluster_3154076"; isCluster="true"; label="WholeStageCodegen (1)"; 1244196 [id="node_1244196" labelType="html" label="MapPartitionsRDD [1244196] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3154075 { id="cluster_3154075"; isCluster="true"; label="Exchange"; 1244197 [id="node_1244197" labelType="html" label="MapPartitionsRDD [1244197] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1244183->1244184; 1244184->1244185; 1244185->1244186; 1244186->1244187; 1244187->1244188; 1244188->1244189; 1244189->1244196; 1244196->1244197; }
1244182,1244183
1244189
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