4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1655803 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
167.5 KiB / 1350
Associated Job Ids:
86059
DAG Visualization
digraph G { id="graph_1655803"; subgraph graph_stage_1655803 { id="graph_stage_1655803"; isCluster="true"; label="Stage 1655803"; 709628 [id="node_709628" labelType="html" label="SQLExecutionRDD [709628] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1779139 { id="cluster_1779139"; isCluster="true"; label="Exchange"; 709623 [id="node_709623" labelType="html" label="ShuffledRowRDD [709623] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779135 { id="cluster_1779135"; isCluster="true"; label="WholeStageCodegen (3)"; 709624 [id="node_709624" labelType="html" label="MapPartitionsRDD [709624] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779134 { id="cluster_1779134"; isCluster="true"; label="DeserializeToObject"; 709625 [id="node_709625" labelType="html" label="MapPartitionsRDD [709625] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779133 { id="cluster_1779133"; isCluster="true"; label="MapPartitions"; 709626 [id="node_709626" labelType="html" label="MapPartitionsRDD [709626] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779130 { id="cluster_1779130"; isCluster="true"; label="WholeStageCodegen (4)"; 709627 [id="node_709627" labelType="html" label="MapPartitionsRDD [709627] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779150 { id="cluster_1779150"; isCluster="true"; label="map"; 709629 [id="node_709629" labelType="html" label="Delta Table State #43 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000000548/_delta_log [709629] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779198 { id="cluster_1779198"; isCluster="true"; label="WholeStageCodegen (1)"; 709642 [id="node_709642" labelType="html" label="MapPartitionsRDD [709642] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1779202 { id="cluster_1779202"; isCluster="true"; label="mapPartitionsInternal"; 709643 [id="node_709643" labelType="html" label="MapPartitionsRDD [709643] [Unordered]<br>start at FileStorageAdapterImpl.java:596}"]; } } 709623->709624; 709624->709625; 709625->709626; 709626->709627; 709627->709628; 709628->709629; 709629->709642; 709642->709643; }
709622,709623
709629
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