4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1253773 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 30
Input Size / Records:
2.2 KiB / 7
Shuffle Write Size / Records:
644.0 B / 7
Associated Job Ids:
40679
DAG Visualization
digraph G { id="graph_1253773"; subgraph graph_stage_1253773 { id="graph_stage_1253773"; isCluster="true"; label="Stage 1253773"; 330073 [id="node_330073" labelType="html" label="SQLExecutionRDD [330073] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; subgraph cluster_849005 { id="cluster_849005"; isCluster="true"; label="Exchange"; 330068 [id="node_330068" labelType="html" label="ShuffledRowRDD [330068] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849004 { id="cluster_849004"; isCluster="true"; label="ObjectHashAggregate"; 330069 [id="node_330069" labelType="html" label="MapPartitionsRDD [330069] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_848983 { id="cluster_848983"; isCluster="true"; label="WholeStageCodegen (13)"; 330070 [id="node_330070" labelType="html" label="MapPartitionsRDD [330070] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_848975 { id="cluster_848975"; isCluster="true"; label="DeserializeToObject"; 330071 [id="node_330071" labelType="html" label="MapPartitionsRDD [330071] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_848969 { id="cluster_848969"; isCluster="true"; label="MapPartitions"; 330072 [id="node_330072" labelType="html" label="MapPartitionsRDD [330072] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849059 { id="cluster_849059"; isCluster="true"; label="mapPartitions"; 330074 [id="node_330074" labelType="html" label="MapPartitionsRDD [330074] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849194 { id="cluster_849194"; isCluster="true"; label="Scan"; 330104 [id="node_330104" labelType="html" label="MapPartitionsRDD [330104] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849183 { id="cluster_849183"; isCluster="true"; label="WholeStageCodegen (1)"; 330105 [id="node_330105" labelType="html" label="MapPartitionsRDD [330105] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } subgraph cluster_849182 { id="cluster_849182"; isCluster="true"; label="Exchange"; 330106 [id="node_330106" labelType="html" label="MapPartitionsRDD [330106] [Indeterminate]<br>start at FileStorageAdapterImpl.java:567}"]; } } 330068->330069; 330069->330070; 330070->330071; 330071->330072; 330072->330073; 330073->330074; 330074->330104; 330104->330105; 330105->330106; }
330067,330068
330074
330073
330068
330069
330070
330071
330072
330074
330104
330105
330106
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