4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 120364 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.7 s
Locality Level Summary:
Process local: 50
Input Size / Records:
46.4 KiB / 295
Shuffle Write Size / Records:
46.7 KiB / 295
Associated Job Ids:
6543
DAG Visualization
digraph G { id="graph_120364"; subgraph graph_stage_120364 { id="graph_stage_120364"; isCluster="true"; label="Stage 120364"; 57993 [id="node_57993" labelType="html" label="SQLExecutionRDD [57993] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_150237 { id="cluster_150237"; isCluster="true"; label="Exchange"; 57988 [id="node_57988" labelType="html" label="ShuffledRowRDD [57988] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150233 { id="cluster_150233"; isCluster="true"; label="WholeStageCodegen (2)"; 57989 [id="node_57989" labelType="html" label="MapPartitionsRDD [57989] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150232 { id="cluster_150232"; isCluster="true"; label="DeserializeToObject"; 57990 [id="node_57990" labelType="html" label="MapPartitionsRDD [57990] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150231 { id="cluster_150231"; isCluster="true"; label="MapPartitions"; 57991 [id="node_57991" labelType="html" label="MapPartitionsRDD [57991] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150228 { id="cluster_150228"; isCluster="true"; label="WholeStageCodegen (3)"; 57992 [id="node_57992" labelType="html" label="MapPartitionsRDD [57992] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150242 { id="cluster_150242"; isCluster="true"; label="map"; 57994 [id="node_57994" labelType="html" label="Delta Table State #10 - hdlfs://ced12e6d-bca7-47af-9525-449cba9023d7.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/out/kpi-curve-update/10000000350/stream-10000000350-1/_delta_log [57994] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150275 { id="cluster_150275"; isCluster="true"; label="WholeStageCodegen (1)"; 58001 [id="node_58001" labelType="html" label="MapPartitionsRDD [58001] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_150274 { id="cluster_150274"; isCluster="true"; label="Exchange"; 58002 [id="node_58002" labelType="html" label="MapPartitionsRDD [58002] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 57988->57989; 57989->57990; 57990->57991; 57991->57992; 57992->57993; 57993->57994; 57994->58001; 58001->58002; }
57987,57988
57994
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