4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 69534 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
10 s
Locality Level Summary:
Node local: 22; Process local: 8
Shuffle Read Size / Records:
46.4 KiB / 73
Associated Job Ids:
25794
DAG Visualization
digraph G { id="graph_69534"; subgraph graph_stage_69534 { id="graph_stage_69534"; isCluster="true"; label="Stage 69534"; 196009 [id="node_196009" labelType="html" label="SQLExecutionRDD [196009] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_516244 { id="cluster_516244"; isCluster="true"; label="Exchange"; 196001 [id="node_196001" labelType="html" label="ShuffledRowRDD [196001] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516243 { id="cluster_516243"; isCluster="true"; label="ObjectHashAggregate"; 196002 [id="node_196002" labelType="html" label="MapPartitionsRDD [196002] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516242 { id="cluster_516242"; isCluster="true"; label="Project"; 196003 [id="node_196003" labelType="html" label="MapPartitionsRDD [196003] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516235 { id="cluster_516235"; isCluster="true"; label="WholeStageCodegen (16)"; 196004 [id="node_196004" labelType="html" label="MapPartitionsRDD [196004] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516234 { id="cluster_516234"; isCluster="true"; label="DeserializeToObject"; 196005 [id="node_196005" labelType="html" label="MapPartitionsRDD [196005] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516233 { id="cluster_516233"; isCluster="true"; label="MapPartitions"; 196006 [id="node_196006" labelType="html" label="MapPartitionsRDD [196006] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516165 { id="cluster_516165"; isCluster="true"; label="WholeStageCodegen (19)"; 196007 [id="node_196007" labelType="html" label="MapPartitionsRDD [196007] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516144 { id="cluster_516144"; isCluster="true"; label="DeserializeToObject"; 196008 [id="node_196008" labelType="html" label="MapPartitionsRDD [196008] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516321 { id="cluster_516321"; isCluster="true"; label="mapPartitions"; 196010 [id="node_196010" labelType="html" label="MapPartitionsRDD [196010] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_516322 { id="cluster_516322"; isCluster="true"; label="mapPartitions"; 196011 [id="node_196011" labelType="html" label="MapPartitionsRDD [196011] [Cached] [Unordered]<br>start at FileStorageAdapterImpl.java:179}"]; } } 196001->196002; 196002->196003; 196003->196004; 196004->196005; 196005->196006; 196006->196007; 196007->196008; 196008->196009; 196009->196010; 196010->196011; }
196000,196001
196011
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