4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1656638 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 30
Input Size / Records:
189.0 KiB / 692
Associated Job Ids:
86103
DAG Visualization
digraph G { id="graph_1656638"; subgraph graph_stage_1656638 { id="graph_stage_1656638"; isCluster="true"; label="Stage 1656638"; 710071 [id="node_710071" labelType="html" label="SQLExecutionRDD [710071] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1780071 { id="cluster_1780071"; isCluster="true"; label="Exchange"; 710066 [id="node_710066" labelType="html" label="ShuffledRowRDD [710066] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780070 { id="cluster_1780070"; isCluster="true"; label="ObjectHashAggregate"; 710067 [id="node_710067" labelType="html" label="MapPartitionsRDD [710067] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780049 { id="cluster_1780049"; isCluster="true"; label="WholeStageCodegen (13)"; 710068 [id="node_710068" labelType="html" label="MapPartitionsRDD [710068] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780040 { id="cluster_1780040"; isCluster="true"; label="DeserializeToObject"; 710069 [id="node_710069" labelType="html" label="MapPartitionsRDD [710069] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780033 { id="cluster_1780033"; isCluster="true"; label="MapPartitions"; 710070 [id="node_710070" labelType="html" label="MapPartitionsRDD [710070] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780125 { id="cluster_1780125"; isCluster="true"; label="mapPartitions"; 710072 [id="node_710072" labelType="html" label="MapPartitionsRDD [710072] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780260 { id="cluster_1780260"; isCluster="true"; label="Scan"; 710102 [id="node_710102" labelType="html" label="MapPartitionsRDD [710102] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780249 { id="cluster_1780249"; isCluster="true"; label="WholeStageCodegen (1)"; 710103 [id="node_710103" labelType="html" label="MapPartitionsRDD [710103] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1780248 { id="cluster_1780248"; isCluster="true"; label="Exchange"; 710104 [id="node_710104" labelType="html" label="MapPartitionsRDD [710104] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 710066->710067; 710067->710068; 710068->710069; 710069->710070; 710070->710071; 710071->710072; 710072->710102; 710102->710103; 710103->710104; }
710065,710066
710072
710071
710066
710067
710068
710069
710070
710072
710102
710103
710104
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