4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 191146 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 50
Input Size / Records:
84.4 KiB / 602
Shuffle Write Size / Records:
84.8 KiB / 602
Associated Job Ids:
52772
DAG Visualization
digraph G { id="graph_191146"; subgraph graph_stage_191146 { id="graph_stage_191146"; isCluster="true"; label="Stage 191146"; 425966 [id="node_425966" labelType="html" label="SQLExecutionRDD [425966] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1113091 { id="cluster_1113091"; isCluster="true"; label="Exchange"; 425961 [id="node_425961" labelType="html" label="ShuffledRowRDD [425961] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113087 { id="cluster_1113087"; isCluster="true"; label="WholeStageCodegen (3)"; 425962 [id="node_425962" labelType="html" label="MapPartitionsRDD [425962] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113086 { id="cluster_1113086"; isCluster="true"; label="DeserializeToObject"; 425963 [id="node_425963" labelType="html" label="MapPartitionsRDD [425963] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113085 { id="cluster_1113085"; isCluster="true"; label="MapPartitions"; 425964 [id="node_425964" labelType="html" label="MapPartitionsRDD [425964] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113082 { id="cluster_1113082"; isCluster="true"; label="WholeStageCodegen (4)"; 425965 [id="node_425965" labelType="html" label="MapPartitionsRDD [425965] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113102 { id="cluster_1113102"; isCluster="true"; label="map"; 425967 [id="node_425967" labelType="html" label="Delta Table State #20 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000532/stream-10000000532-1/_delta_log [425967] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113139 { id="cluster_1113139"; isCluster="true"; label="WholeStageCodegen (1)"; 425974 [id="node_425974" labelType="html" label="MapPartitionsRDD [425974] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1113138 { id="cluster_1113138"; isCluster="true"; label="Exchange"; 425975 [id="node_425975" labelType="html" label="MapPartitionsRDD [425975] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 425961->425962; 425962->425963; 425963->425964; 425964->425965; 425965->425966; 425966->425967; 425967->425974; 425974->425975; }
425960,425961
425967
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