4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 445889 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.1 s
Locality Level Summary:
Process local: 50
Input Size / Records:
1430.0 B / 1
Associated Job Ids:
154720
DAG Visualization
digraph G { id="graph_445889"; subgraph graph_stage_445889 { id="graph_stage_445889"; isCluster="true"; label="Stage 445889"; 1242046 [id="node_1242046" labelType="html" label="SQLExecutionRDD [1242046] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 1242050 [id="node_1242050" labelType="html" label="SQLExecutionRDD [1242050] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_3148817 { id="cluster_3148817"; isCluster="true"; label="Exchange"; 1242041 [id="node_1242041" labelType="html" label="ShuffledRowRDD [1242041] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148813 { id="cluster_3148813"; isCluster="true"; label="WholeStageCodegen (2)"; 1242042 [id="node_1242042" labelType="html" label="MapPartitionsRDD [1242042] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148812 { id="cluster_3148812"; isCluster="true"; label="DeserializeToObject"; 1242043 [id="node_1242043" labelType="html" label="MapPartitionsRDD [1242043] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148811 { id="cluster_3148811"; isCluster="true"; label="MapPartitions"; 1242044 [id="node_1242044" labelType="html" label="MapPartitionsRDD [1242044] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148808 { id="cluster_3148808"; isCluster="true"; label="WholeStageCodegen (3)"; 1242045 [id="node_1242045" labelType="html" label="MapPartitionsRDD [1242045] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148822 { id="cluster_3148822"; isCluster="true"; label="map"; 1242047 [id="node_1242047" labelType="html" label="Delta Table State #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001651/0_1_10000001651/_delta_log [1242047] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148824 { id="cluster_3148824"; isCluster="true"; label="WholeStageCodegen (1)"; 1242048 [id="node_1242048" labelType="html" label="MapPartitionsRDD [1242048] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148823 { id="cluster_3148823"; isCluster="true"; label="Project"; 1242049 [id="node_1242049" labelType="html" label="MapPartitionsRDD [1242049] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3148827 { id="cluster_3148827"; isCluster="true"; label="map"; 1242051 [id="node_1242051" labelType="html" label="Delta Table State with Stats #0 - hdlfs://f1cc4c74-cdd4-440e-abc7-4e0157628b42.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000001651/0_1_10000001651/_delta_log [1242051] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149313 { id="cluster_3149313"; isCluster="true"; label="WholeStageCodegen (1)"; 1242250 [id="node_1242250" labelType="html" label="MapPartitionsRDD [1242250] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_3149317 { id="cluster_3149317"; isCluster="true"; label="mapPartitionsInternal"; 1242251 [id="node_1242251" labelType="html" label="MapPartitionsRDD [1242251] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 1242041->1242042; 1242042->1242043; 1242043->1242044; 1242044->1242045; 1242045->1242046; 1242046->1242047; 1242047->1242048; 1242048->1242049; 1242049->1242050; 1242050->1242051; 1242051->1242250; 1242250->1242251; }
1242040,1242041
1242047
1242051
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