4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190771 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 50
Input Size / Records:
69.9 KiB / 272
Associated Job Ids:
52697
DAG Visualization
digraph G { id="graph_190771"; subgraph graph_stage_190771 { id="graph_stage_190771"; isCluster="true"; label="Stage 190771"; 424940 [id="node_424940" labelType="html" label="SQLExecutionRDD [424940] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1110566 { id="cluster_1110566"; isCluster="true"; label="Exchange"; 424935 [id="node_424935" labelType="html" label="ShuffledRowRDD [424935] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110562 { id="cluster_1110562"; isCluster="true"; label="WholeStageCodegen (2)"; 424936 [id="node_424936" labelType="html" label="MapPartitionsRDD [424936] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110561 { id="cluster_1110561"; isCluster="true"; label="DeserializeToObject"; 424937 [id="node_424937" labelType="html" label="MapPartitionsRDD [424937] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110560 { id="cluster_1110560"; isCluster="true"; label="MapPartitions"; 424938 [id="node_424938" labelType="html" label="MapPartitionsRDD [424938] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110557 { id="cluster_1110557"; isCluster="true"; label="WholeStageCodegen (3)"; 424939 [id="node_424939" labelType="html" label="MapPartitionsRDD [424939] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110571 { id="cluster_1110571"; isCluster="true"; label="map"; 424941 [id="node_424941" labelType="html" label="Delta Table State #9 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000000532/stream-10000000532-3/shardId=0_6_10000000532/_delta_log [424941] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110597 { id="cluster_1110597"; isCluster="true"; label="WholeStageCodegen (1)"; 424948 [id="node_424948" labelType="html" label="MapPartitionsRDD [424948] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1110601 { id="cluster_1110601"; isCluster="true"; label="mapPartitionsInternal"; 424949 [id="node_424949" labelType="html" label="MapPartitionsRDD [424949] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 424935->424936; 424936->424937; 424937->424938; 424938->424939; 424939->424940; 424940->424941; 424941->424948; 424948->424949; }
424934,424935
424941
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