4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 100733 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
12 s
Locality Level Summary:
Node local: 1; Process local: 49
Shuffle Read Size / Records:
868.0 B / 3
Associated Job Ids:
5328
DAG Visualization
digraph G { id="graph_100733"; subgraph graph_stage_100733 { id="graph_stage_100733"; isCluster="true"; label="Stage 100733"; 46915 [id="node_46915" labelType="html" label="SQLExecutionRDD [46915] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_121712 { id="cluster_121712"; isCluster="true"; label="Exchange"; 46910 [id="node_46910" labelType="html" label="ShuffledRowRDD [46910] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121708 { id="cluster_121708"; isCluster="true"; label="WholeStageCodegen (2)"; 46911 [id="node_46911" labelType="html" label="MapPartitionsRDD [46911] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121707 { id="cluster_121707"; isCluster="true"; label="DeserializeToObject"; 46912 [id="node_46912" labelType="html" label="MapPartitionsRDD [46912] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121706 { id="cluster_121706"; isCluster="true"; label="MapPartitions"; 46913 [id="node_46913" labelType="html" label="MapPartitionsRDD [46913] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121703 { id="cluster_121703"; isCluster="true"; label="WholeStageCodegen (3)"; 46914 [id="node_46914" labelType="html" label="MapPartitionsRDD [46914] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121717 { id="cluster_121717"; isCluster="true"; label="map"; 46916 [id="node_46916" labelType="html" label="Delta Table State #0 - hdlfs://770f0770-bd0c-456f-b83b-9649926e0857.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000678/stream-10000000678-1/_delta_log [46916] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121723 { id="cluster_121723"; isCluster="true"; label="WholeStageCodegen (1)"; 46917 [id="node_46917" labelType="html" label="MapPartitionsRDD [46917] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_121722 { id="cluster_121722"; isCluster="true"; label="Exchange"; 46918 [id="node_46918" labelType="html" label="MapPartitionsRDD [46918] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 46919 [id="node_46919" labelType="html" label="MapPartitionsRDD [46919] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; 46920 [id="node_46920" labelType="html" label="MapPartitionsRDD [46920] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 46910->46911; 46911->46912; 46912->46913; 46913->46914; 46914->46915; 46915->46916; 46916->46917; 46917->46918; 46918->46919; 46919->46920; }
46909,46910
46916
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