4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 105702 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
10 s
Locality Level Summary:
Node local: 1; Process local: 49
Shuffle Read Size / Records:
868.0 B / 3
Associated Job Ids:
5801
DAG Visualization
digraph G { id="graph_105702"; subgraph graph_stage_105702 { id="graph_stage_105702"; isCluster="true"; label="Stage 105702"; 50517 [id="node_50517" labelType="html" label="SQLExecutionRDD [50517] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_131630 { id="cluster_131630"; isCluster="true"; label="Exchange"; 50512 [id="node_50512" labelType="html" label="ShuffledRowRDD [50512] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131626 { id="cluster_131626"; isCluster="true"; label="WholeStageCodegen (2)"; 50513 [id="node_50513" labelType="html" label="MapPartitionsRDD [50513] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131625 { id="cluster_131625"; isCluster="true"; label="DeserializeToObject"; 50514 [id="node_50514" labelType="html" label="MapPartitionsRDD [50514] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131624 { id="cluster_131624"; isCluster="true"; label="MapPartitions"; 50515 [id="node_50515" labelType="html" label="MapPartitionsRDD [50515] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131621 { id="cluster_131621"; isCluster="true"; label="WholeStageCodegen (3)"; 50516 [id="node_50516" labelType="html" label="MapPartitionsRDD [50516] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131635 { id="cluster_131635"; isCluster="true"; label="map"; 50518 [id="node_50518" labelType="html" label="Delta Table State #0 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000349/stream-10000000349-1/_delta_log [50518] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131641 { id="cluster_131641"; isCluster="true"; label="WholeStageCodegen (1)"; 50519 [id="node_50519" labelType="html" label="MapPartitionsRDD [50519] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_131640 { id="cluster_131640"; isCluster="true"; label="Exchange"; 50520 [id="node_50520" labelType="html" label="MapPartitionsRDD [50520] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 50521 [id="node_50521" labelType="html" label="MapPartitionsRDD [50521] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 50522 [id="node_50522" labelType="html" label="MapPartitionsRDD [50522] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 50512->50513; 50513->50514; 50514->50515; 50515->50516; 50516->50517; 50517->50518; 50518->50519; 50519->50520; 50520->50521; 50521->50522; }
50511,50512
50518
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