4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 278735 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Node local: 29; Process local: 1
Shuffle Read Size / Records:
125.3 KiB / 230
Associated Job Ids:
96740
DAG Visualization
digraph G { id="graph_278735"; subgraph graph_stage_278735 { id="graph_stage_278735"; isCluster="true"; label="Stage 278735"; 789934 [id="node_789934" labelType="html" label="SQLExecutionRDD [789934] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_1999791 { id="cluster_1999791"; isCluster="true"; label="Exchange"; 789926 [id="node_789926" labelType="html" label="ShuffledRowRDD [789926] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999790 { id="cluster_1999790"; isCluster="true"; label="ObjectHashAggregate"; 789927 [id="node_789927" labelType="html" label="MapPartitionsRDD [789927] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999789 { id="cluster_1999789"; isCluster="true"; label="Project"; 789928 [id="node_789928" labelType="html" label="MapPartitionsRDD [789928] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999782 { id="cluster_1999782"; isCluster="true"; label="WholeStageCodegen (11)"; 789929 [id="node_789929" labelType="html" label="MapPartitionsRDD [789929] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999781 { id="cluster_1999781"; isCluster="true"; label="DeserializeToObject"; 789930 [id="node_789930" labelType="html" label="MapPartitionsRDD [789930] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999780 { id="cluster_1999780"; isCluster="true"; label="MapPartitions"; 789931 [id="node_789931" labelType="html" label="MapPartitionsRDD [789931] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999722 { id="cluster_1999722"; isCluster="true"; label="WholeStageCodegen (14)"; 789932 [id="node_789932" labelType="html" label="MapPartitionsRDD [789932] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999707 { id="cluster_1999707"; isCluster="true"; label="DeserializeToObject"; 789933 [id="node_789933" labelType="html" label="MapPartitionsRDD [789933] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999841 { id="cluster_1999841"; isCluster="true"; label="mapPartitions"; 789935 [id="node_789935" labelType="html" label="MapPartitionsRDD [789935] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_1999842 { id="cluster_1999842"; isCluster="true"; label="mapPartitions"; 789936 [id="node_789936" labelType="html" label="MapPartitionsRDD [789936] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:174}"]; } } 789926->789927; 789927->789928; 789928->789929; 789929->789930; 789930->789931; 789931->789932; 789932->789933; 789933->789934; 789934->789935; 789935->789936; }
789925,789926
789936
Event Timeline
Enable zooming
Tasks: 30. 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