4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1033483 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
3 s
Locality Level Summary:
Process local: 30
Input Size / Records:
641.6 KiB / 2354
Associated Job Ids:
52712
DAG Visualization
digraph G { id="graph_1033483"; subgraph graph_stage_1033483 { id="graph_stage_1033483"; isCluster="true"; label="Stage 1033483"; 434337 [id="node_434337" labelType="html" label="SQLExecutionRDD [434337] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; subgraph cluster_1088088 { id="cluster_1088088"; isCluster="true"; label="Exchange"; 434332 [id="node_434332" labelType="html" label="ShuffledRowRDD [434332] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088087 { id="cluster_1088087"; isCluster="true"; label="ObjectHashAggregate"; 434333 [id="node_434333" labelType="html" label="MapPartitionsRDD [434333] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088066 { id="cluster_1088066"; isCluster="true"; label="WholeStageCodegen (13)"; 434334 [id="node_434334" labelType="html" label="MapPartitionsRDD [434334] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088057 { id="cluster_1088057"; isCluster="true"; label="DeserializeToObject"; 434335 [id="node_434335" labelType="html" label="MapPartitionsRDD [434335] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088050 { id="cluster_1088050"; isCluster="true"; label="MapPartitions"; 434336 [id="node_434336" labelType="html" label="MapPartitionsRDD [434336] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088142 { id="cluster_1088142"; isCluster="true"; label="mapPartitions"; 434338 [id="node_434338" labelType="html" label="MapPartitionsRDD [434338] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088277 { id="cluster_1088277"; isCluster="true"; label="Scan"; 434368 [id="node_434368" labelType="html" label="MapPartitionsRDD [434368] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088266 { id="cluster_1088266"; isCluster="true"; label="WholeStageCodegen (1)"; 434369 [id="node_434369" labelType="html" label="MapPartitionsRDD [434369] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } subgraph cluster_1088265 { id="cluster_1088265"; isCluster="true"; label="Exchange"; 434370 [id="node_434370" labelType="html" label="MapPartitionsRDD [434370] [Indeterminate]<br>start at FileStorageAdapterImpl.java:596}"]; } } 434332->434333; 434333->434334; 434334->434335; 434335->434336; 434336->434337; 434337->434338; 434338->434368; 434368->434369; 434369->434370; }
434331,434332
434338
434337
434332
434333
434334
434335
434336
434338
434368
434369
434370
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