4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 3728563 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
37.5 KiB / 152
Associated Job Ids:
127292
DAG Visualization
digraph G { id="graph_3728563"; subgraph graph_stage_3728563 { id="graph_stage_3728563"; isCluster="true"; label="Stage 3728563"; 1062584 [id="node_1062584" labelType="html" label="SQLExecutionRDD [1062584] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_2797971 { id="cluster_2797971"; isCluster="true"; label="Exchange"; 1062579 [id="node_1062579" labelType="html" label="ShuffledRowRDD [1062579] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797967 { id="cluster_2797967"; isCluster="true"; label="WholeStageCodegen (2)"; 1062580 [id="node_1062580" labelType="html" label="MapPartitionsRDD [1062580] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797966 { id="cluster_2797966"; isCluster="true"; label="DeserializeToObject"; 1062581 [id="node_1062581" labelType="html" label="MapPartitionsRDD [1062581] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797965 { id="cluster_2797965"; isCluster="true"; label="MapPartitions"; 1062582 [id="node_1062582" labelType="html" label="MapPartitionsRDD [1062582] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797962 { id="cluster_2797962"; isCluster="true"; label="WholeStageCodegen (3)"; 1062583 [id="node_1062583" labelType="html" label="MapPartitionsRDD [1062583] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2797976 { id="cluster_2797976"; isCluster="true"; label="map"; 1062585 [id="node_1062585" labelType="html" label="Delta Table State #4 - hdlfs://332d7051-0d16-44f5-ae76-bf2dcf30365f.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/kpi-curve-cache/10000001452/_delta_log [1062585] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2798020 { id="cluster_2798020"; isCluster="true"; label="WholeStageCodegen (1)"; 1062598 [id="node_1062598" labelType="html" label="MapPartitionsRDD [1062598] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2798024 { id="cluster_2798024"; isCluster="true"; label="mapPartitionsInternal"; 1062599 [id="node_1062599" labelType="html" label="MapPartitionsRDD [1062599] [Unordered]<br>start at FileStorageAdapterImpl.java:598}"]; } } 1062579->1062580; 1062580->1062581; 1062581->1062582; 1062582->1062583; 1062583->1062584; 1062584->1062585; 1062585->1062598; 1062598->1062599; }
1062578,1062579
1062585
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