4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 995 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.1 s
Locality Level Summary:
Process local: 50
Input Size / Records:
1485.0 B / 2
Associated Job Ids:
455
DAG Visualization
digraph G { id="graph_995"; subgraph graph_stage_995 { id="graph_stage_995"; isCluster="true"; label="Stage 995"; 2593 [id="node_2593" labelType="html" label="SQLExecutionRDD [2593] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_8054 { id="cluster_8054"; isCluster="true"; label="Exchange"; 2588 [id="node_2588" labelType="html" label="ShuffledRowRDD [2588] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8050 { id="cluster_8050"; isCluster="true"; label="WholeStageCodegen (2)"; 2589 [id="node_2589" labelType="html" label="MapPartitionsRDD [2589] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8049 { id="cluster_8049"; isCluster="true"; label="DeserializeToObject"; 2590 [id="node_2590" labelType="html" label="MapPartitionsRDD [2590] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8048 { id="cluster_8048"; isCluster="true"; label="MapPartitions"; 2591 [id="node_2591" labelType="html" label="MapPartitionsRDD [2591] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8045 { id="cluster_8045"; isCluster="true"; label="WholeStageCodegen (3)"; 2592 [id="node_2592" labelType="html" label="MapPartitionsRDD [2592] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8059 { id="cluster_8059"; isCluster="true"; label="map"; 2594 [id="node_2594" labelType="html" label="Delta Table State #0 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000006/stream-10000000006-1/_delta_log [2594] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8065 { id="cluster_8065"; isCluster="true"; label="WholeStageCodegen (1)"; 2595 [id="node_2595" labelType="html" label="MapPartitionsRDD [2595] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_8064 { id="cluster_8064"; isCluster="true"; label="Exchange"; 2599 [id="node_2599" labelType="html" label="MapPartitionsRDD [2599] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 2588->2589; 2589->2590; 2590->2591; 2591->2592; 2592->2593; 2593->2594; 2594->2595; 2595->2599; }
2587,2588
2594
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