4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 926 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 ms
Locality Level Summary:
Process local: 50
Input Size / Records:
1432.0 B / 1
Associated Job Ids:
429
DAG Visualization
digraph G { id="graph_926"; subgraph graph_stage_926 { id="graph_stage_926"; isCluster="true"; label="Stage 926"; 2038 [id="node_2038" labelType="html" label="SQLExecutionRDD [2038] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; 2042 [id="node_2042" labelType="html" label="SQLExecutionRDD [2042] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_6715 { id="cluster_6715"; isCluster="true"; label="Exchange"; 2033 [id="node_2033" labelType="html" label="ShuffledRowRDD [2033] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6711 { id="cluster_6711"; isCluster="true"; label="WholeStageCodegen (2)"; 2034 [id="node_2034" labelType="html" label="MapPartitionsRDD [2034] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6710 { id="cluster_6710"; isCluster="true"; label="DeserializeToObject"; 2035 [id="node_2035" labelType="html" label="MapPartitionsRDD [2035] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6709 { id="cluster_6709"; isCluster="true"; label="MapPartitions"; 2036 [id="node_2036" labelType="html" label="MapPartitionsRDD [2036] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6706 { id="cluster_6706"; isCluster="true"; label="WholeStageCodegen (3)"; 2037 [id="node_2037" labelType="html" label="MapPartitionsRDD [2037] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6720 { id="cluster_6720"; isCluster="true"; label="map"; 2039 [id="node_2039" labelType="html" label="Delta Table State #0 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000005/0_1_10000000005/_delta_log [2039] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6722 { id="cluster_6722"; isCluster="true"; label="WholeStageCodegen (1)"; 2040 [id="node_2040" labelType="html" label="MapPartitionsRDD [2040] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6721 { id="cluster_6721"; isCluster="true"; label="Project"; 2041 [id="node_2041" labelType="html" label="MapPartitionsRDD [2041] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_6725 { id="cluster_6725"; isCluster="true"; label="map"; 2043 [id="node_2043" labelType="html" label="Delta Table State with Stats #0 - hdlfs://9b46f9d5-066e-49af-bc5c-7af37534ca4d.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/data-snapshot/10000000005/0_1_10000000005/_delta_log [2043] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7582 { id="cluster_7582"; isCluster="true"; label="WholeStageCodegen (1)"; 2398 [id="node_2398" labelType="html" label="MapPartitionsRDD [2398] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_7586 { id="cluster_7586"; isCluster="true"; label="mapPartitionsInternal"; 2399 [id="node_2399" labelType="html" label="MapPartitionsRDD [2399] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 2033->2034; 2034->2035; 2035->2036; 2036->2037; 2037->2038; 2038->2039; 2039->2040; 2040->2041; 2041->2042; 2042->2043; 2043->2398; 2398->2399; }
2032,2033
2039
2043
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