4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 190200 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
28 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
12.0 KiB / 37
Associated Job Ids:
52581
DAG Visualization
digraph G { id="graph_190200"; subgraph graph_stage_190200 { id="graph_stage_190200"; isCluster="true"; label="Stage 190200"; 414121 [id="node_414121" labelType="html" label="SQLExecutionRDD [414121] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 414125 [id="node_414125" labelType="html" label="SQLExecutionRDD [414125] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1083972 { id="cluster_1083972"; isCluster="true"; label="Exchange"; 414116 [id="node_414116" labelType="html" label="ShuffledRowRDD [414116] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083968 { id="cluster_1083968"; isCluster="true"; label="WholeStageCodegen (2)"; 414117 [id="node_414117" labelType="html" label="MapPartitionsRDD [414117] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083967 { id="cluster_1083967"; isCluster="true"; label="DeserializeToObject"; 414118 [id="node_414118" labelType="html" label="MapPartitionsRDD [414118] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083966 { id="cluster_1083966"; isCluster="true"; label="MapPartitions"; 414119 [id="node_414119" labelType="html" label="MapPartitionsRDD [414119] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083963 { id="cluster_1083963"; isCluster="true"; label="WholeStageCodegen (3)"; 414120 [id="node_414120" labelType="html" label="MapPartitionsRDD [414120] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083977 { id="cluster_1083977"; isCluster="true"; label="map"; 414122 [id="node_414122" labelType="html" label="Delta Table State #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000532/0_1_10000000532/_delta_log [414122] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083979 { id="cluster_1083979"; isCluster="true"; label="WholeStageCodegen (1)"; 414123 [id="node_414123" labelType="html" label="MapPartitionsRDD [414123] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083978 { id="cluster_1083978"; isCluster="true"; label="Project"; 414124 [id="node_414124" labelType="html" label="MapPartitionsRDD [414124] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1083982 { id="cluster_1083982"; isCluster="true"; label="map"; 414126 [id="node_414126" labelType="html" label="Delta Table State with Stats #0 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000532/0_1_10000000532/_delta_log [414126] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106904 { id="cluster_1106904"; isCluster="true"; label="WholeStageCodegen (1)"; 423429 [id="node_423429" labelType="html" label="MapPartitionsRDD [423429] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1106903 { id="cluster_1106903"; isCluster="true"; label="Scan parquet "; 423430 [id="node_423430" labelType="html" label="MapPartitionsRDD [423430] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 414116->414117; 414117->414118; 414118->414119; 414119->414120; 414120->414121; 414121->414122; 414122->414123; 414123->414124; 414124->414125; 414125->414126; 414126->423429; 423429->423430; }
414115,414116
414122
414126
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