4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445812 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
6 s
Locality Level Summary:
Node local: 1; Process local: 49
Shuffle Read Size / Records:
843.0 B / 3
Shuffle Write Size / Records:
5.3 KiB / 50
Associated Job Ids:
154695
DAG Visualization
digraph G { id="graph_445812"; subgraph graph_stage_445812 { id="graph_stage_445812"; isCluster="true"; label="Stage 445812"; 1242016 [id="node_1242016" labelType="html" label="SQLExecutionRDD [1242016] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3148747 { id="cluster_3148747"; isCluster="true"; label="Exchange"; 1242011 [id="node_1242011" labelType="html" label="ShuffledRowRDD [1242011] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148743 { id="cluster_3148743"; isCluster="true"; label="WholeStageCodegen (2)"; 1242012 [id="node_1242012" labelType="html" label="MapPartitionsRDD [1242012] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148742 { id="cluster_3148742"; isCluster="true"; label="DeserializeToObject"; 1242013 [id="node_1242013" labelType="html" label="MapPartitionsRDD [1242013] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148741 { id="cluster_3148741"; isCluster="true"; label="MapPartitions"; 1242014 [id="node_1242014" labelType="html" label="MapPartitionsRDD [1242014] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148738 { id="cluster_3148738"; isCluster="true"; label="WholeStageCodegen (3)"; 1242015 [id="node_1242015" labelType="html" label="MapPartitionsRDD [1242015] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148752 { id="cluster_3148752"; isCluster="true"; label="map"; 1242017 [id="node_1242017" labelType="html" label="Delta Table State #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-quantities/10000001651/stream-10000001651-1/shardId=0_1_10000001651/_delta_log [1242017] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148756 { id="cluster_3148756"; isCluster="true"; label="WholeStageCodegen (1)"; 1242018 [id="node_1242018" labelType="html" label="MapPartitionsRDD [1242018] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148755 { id="cluster_3148755"; isCluster="true"; label="ObjectHashAggregate"; 1242019 [id="node_1242019" labelType="html" label="MapPartitionsRDD [1242019] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148754 { id="cluster_3148754"; isCluster="true"; label="Exchange"; 1242020 [id="node_1242020" labelType="html" label="MapPartitionsRDD [1242020] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242011->1242012; 1242012->1242013; 1242013->1242014; 1242014->1242015; 1242015->1242016; 1242016->1242017; 1242017->1242018; 1242018->1242019; 1242019->1242020; }
1242010,1242011
1242017
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