4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1271727 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
43.1 KiB / 212
Associated Job Ids:
41060
DAG Visualization
digraph G { id="graph_1271727"; subgraph graph_stage_1271727 { id="graph_stage_1271727"; isCluster="true"; label="Stage 1271727"; 333583 [id="node_333583" labelType="html" label="SQLExecutionRDD [333583] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_858043 { id="cluster_858043"; isCluster="true"; label="Exchange"; 333578 [id="node_333578" labelType="html" label="ShuffledRowRDD [333578] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858039 { id="cluster_858039"; isCluster="true"; label="WholeStageCodegen (2)"; 333579 [id="node_333579" labelType="html" label="MapPartitionsRDD [333579] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858038 { id="cluster_858038"; isCluster="true"; label="DeserializeToObject"; 333580 [id="node_333580" labelType="html" label="MapPartitionsRDD [333580] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858037 { id="cluster_858037"; isCluster="true"; label="MapPartitions"; 333581 [id="node_333581" labelType="html" label="MapPartitionsRDD [333581] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858034 { id="cluster_858034"; isCluster="true"; label="WholeStageCodegen (3)"; 333582 [id="node_333582" labelType="html" label="MapPartitionsRDD [333582] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858048 { id="cluster_858048"; isCluster="true"; label="map"; 333584 [id="node_333584" labelType="html" label="Delta Table State #6 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000000244/_delta_log [333584] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858092 { id="cluster_858092"; isCluster="true"; label="WholeStageCodegen (1)"; 333597 [id="node_333597" labelType="html" label="MapPartitionsRDD [333597] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_858096 { id="cluster_858096"; isCluster="true"; label="mapPartitionsInternal"; 333598 [id="node_333598" labelType="html" label="MapPartitionsRDD [333598] [Unordered]<br>start at FileStorageAdapterImpl.java:567}"]; } } 333578->333579; 333579->333580; 333580->333581; 333581->333582; 333582->333583; 333583->333584; 333584->333597; 333597->333598; }
333577,333578
333584
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