4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 112280 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Node local: 47; Process local: 3
Shuffle Read Size / Records:
63.0 KiB / 188
Shuffle Write Size / Records:
6.0 KiB / 50
Associated Job Ids:
6120
DAG Visualization
digraph G { id="graph_112280"; subgraph graph_stage_112280 { id="graph_stage_112280"; isCluster="true"; label="Stage 112280"; 53680 [id="node_53680" labelType="html" label="SQLExecutionRDD [53680] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_139616 { id="cluster_139616"; isCluster="true"; label="Exchange"; 53675 [id="node_53675" labelType="html" label="ShuffledRowRDD [53675] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139612 { id="cluster_139612"; isCluster="true"; label="WholeStageCodegen (2)"; 53676 [id="node_53676" labelType="html" label="MapPartitionsRDD [53676] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139611 { id="cluster_139611"; isCluster="true"; label="DeserializeToObject"; 53677 [id="node_53677" labelType="html" label="MapPartitionsRDD [53677] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139610 { id="cluster_139610"; isCluster="true"; label="MapPartitions"; 53678 [id="node_53678" labelType="html" label="MapPartitionsRDD [53678] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139607 { id="cluster_139607"; isCluster="true"; label="WholeStageCodegen (3)"; 53679 [id="node_53679" labelType="html" label="MapPartitionsRDD [53679] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139621 { id="cluster_139621"; isCluster="true"; label="map"; 53681 [id="node_53681" 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/10000000349/stream-10000000349-1/_delta_log [53681] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139625 { id="cluster_139625"; isCluster="true"; label="WholeStageCodegen (1)"; 53682 [id="node_53682" labelType="html" label="MapPartitionsRDD [53682] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139624 { id="cluster_139624"; isCluster="true"; label="ObjectHashAggregate"; 53683 [id="node_53683" labelType="html" label="MapPartitionsRDD [53683] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_139623 { id="cluster_139623"; isCluster="true"; label="Exchange"; 53684 [id="node_53684" labelType="html" label="MapPartitionsRDD [53684] [Unordered]<br>start at FileStorageAdapterImpl.java:171}"]; } } 53675->53676; 53676->53677; 53677->53678; 53678->53679; 53679->53680; 53680->53681; 53681->53682; 53682->53683; 53683->53684; }
53674,53675
53681
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