4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 27783 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
12 s
Locality Level Summary:
Node local: 25; Process local: 5
Shuffle Read Size / Records:
49.4 KiB / 73
Associated Job Ids:
10379
DAG Visualization
digraph G { id="graph_27783"; subgraph graph_stage_27783 { id="graph_stage_27783"; isCluster="true"; label="Stage 27783"; 78066 [id="node_78066" labelType="html" label="SQLExecutionRDD [78066] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_205701 { id="cluster_205701"; isCluster="true"; label="Exchange"; 78058 [id="node_78058" labelType="html" label="ShuffledRowRDD [78058] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205700 { id="cluster_205700"; isCluster="true"; label="ObjectHashAggregate"; 78059 [id="node_78059" labelType="html" label="MapPartitionsRDD [78059] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205699 { id="cluster_205699"; isCluster="true"; label="Project"; 78060 [id="node_78060" labelType="html" label="MapPartitionsRDD [78060] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205692 { id="cluster_205692"; isCluster="true"; label="WholeStageCodegen (16)"; 78061 [id="node_78061" labelType="html" label="MapPartitionsRDD [78061] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205691 { id="cluster_205691"; isCluster="true"; label="DeserializeToObject"; 78062 [id="node_78062" labelType="html" label="MapPartitionsRDD [78062] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205690 { id="cluster_205690"; isCluster="true"; label="MapPartitions"; 78063 [id="node_78063" labelType="html" label="MapPartitionsRDD [78063] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205623 { id="cluster_205623"; isCluster="true"; label="WholeStageCodegen (19)"; 78064 [id="node_78064" labelType="html" label="MapPartitionsRDD [78064] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205601 { id="cluster_205601"; isCluster="true"; label="DeserializeToObject"; 78065 [id="node_78065" labelType="html" label="MapPartitionsRDD [78065] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205778 { id="cluster_205778"; isCluster="true"; label="mapPartitions"; 78067 [id="node_78067" labelType="html" label="MapPartitionsRDD [78067] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_205779 { id="cluster_205779"; isCluster="true"; label="mapPartitions"; 78068 [id="node_78068" labelType="html" label="MapPartitionsRDD [78068] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 78058->78059; 78059->78060; 78060->78061; 78061->78062; 78062->78063; 78063->78064; 78064->78065; 78065->78066; 78066->78067; 78067->78068; }
78057,78058
78068
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