4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69438 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.1 s
Locality Level Summary:
Process local: 50
Input Size / Records:
11.7 KiB / 37
Associated Job Ids:
25760
DAG Visualization
digraph G { id="graph_69438"; subgraph graph_stage_69438 { id="graph_stage_69438"; isCluster="true"; label="Stage 69438"; 192158 [id="node_192158" labelType="html" label="SQLExecutionRDD [192158] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; 192162 [id="node_192162" labelType="html" label="SQLExecutionRDD [192162] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_506908 { id="cluster_506908"; isCluster="true"; label="Exchange"; 192153 [id="node_192153" labelType="html" label="ShuffledRowRDD [192153] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506904 { id="cluster_506904"; isCluster="true"; label="WholeStageCodegen (2)"; 192154 [id="node_192154" labelType="html" label="MapPartitionsRDD [192154] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506903 { id="cluster_506903"; isCluster="true"; label="DeserializeToObject"; 192155 [id="node_192155" labelType="html" label="MapPartitionsRDD [192155] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506902 { id="cluster_506902"; isCluster="true"; label="MapPartitions"; 192156 [id="node_192156" labelType="html" label="MapPartitionsRDD [192156] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506899 { id="cluster_506899"; isCluster="true"; label="WholeStageCodegen (3)"; 192157 [id="node_192157" labelType="html" label="MapPartitionsRDD [192157] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506913 { id="cluster_506913"; isCluster="true"; label="map"; 192159 [id="node_192159" labelType="html" label="Delta Table State #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001136/0_1_10000001136/_delta_log [192159] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506915 { id="cluster_506915"; isCluster="true"; label="WholeStageCodegen (1)"; 192160 [id="node_192160" labelType="html" label="MapPartitionsRDD [192160] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506914 { id="cluster_506914"; isCluster="true"; label="Project"; 192161 [id="node_192161" labelType="html" label="MapPartitionsRDD [192161] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_506918 { id="cluster_506918"; isCluster="true"; label="map"; 192163 [id="node_192163" labelType="html" label="Delta Table State with Stats #0 - hdlfs://25570170-65a4-43d6-a97a-474f9553b696.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001136/0_1_10000001136/_delta_log [192163] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515593 { id="cluster_515593"; isCluster="true"; label="WholeStageCodegen (1)"; 195712 [id="node_195712" labelType="html" label="MapPartitionsRDD [195712] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_515597 { id="cluster_515597"; isCluster="true"; label="mapPartitionsInternal"; 195713 [id="node_195713" labelType="html" label="MapPartitionsRDD [195713] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 192153->192154; 192154->192155; 192155->192156; 192156->192157; 192157->192158; 192158->192159; 192159->192160; 192160->192161; 192161->192162; 192162->192163; 192163->195712; 195712->195713; }
192152,192153
192159
192163
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