4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 3725502 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
16 ms
Locality Level Summary:
Process local: 30
Input Size / Records:
1004.0 B / 1
Shuffle Write Size / Records:
92.0 B / 1
Associated Job Ids:
127221
DAG Visualization
digraph G { id="graph_3725502"; subgraph graph_stage_3725502 { id="graph_stage_3725502"; isCluster="true"; label="Stage 3725502"; 1061930 [id="node_1061930" labelType="html" label="SQLExecutionRDD [1061930] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_2796208 { id="cluster_2796208"; isCluster="true"; label="Exchange"; 1061925 [id="node_1061925" labelType="html" label="ShuffledRowRDD [1061925] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796207 { id="cluster_2796207"; isCluster="true"; label="ObjectHashAggregate"; 1061926 [id="node_1061926" labelType="html" label="MapPartitionsRDD [1061926] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796186 { id="cluster_2796186"; isCluster="true"; label="WholeStageCodegen (11)"; 1061927 [id="node_1061927" labelType="html" label="MapPartitionsRDD [1061927] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796170 { id="cluster_2796170"; isCluster="true"; label="DeserializeToObject"; 1061928 [id="node_1061928" labelType="html" label="MapPartitionsRDD [1061928] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796160 { id="cluster_2796160"; isCluster="true"; label="MapPartitions"; 1061929 [id="node_1061929" labelType="html" label="MapPartitionsRDD [1061929] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796253 { id="cluster_2796253"; isCluster="true"; label="mapPartitions"; 1061931 [id="node_1061931" labelType="html" label="MapPartitionsRDD [1061931] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796427 { id="cluster_2796427"; isCluster="true"; label="Scan"; 1061973 [id="node_1061973" labelType="html" label="MapPartitionsRDD [1061973] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796416 { id="cluster_2796416"; isCluster="true"; label="WholeStageCodegen (1)"; 1061974 [id="node_1061974" labelType="html" label="MapPartitionsRDD [1061974] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796415 { id="cluster_2796415"; isCluster="true"; label="Exchange"; 1061975 [id="node_1061975" labelType="html" label="MapPartitionsRDD [1061975] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 1061925->1061926; 1061926->1061927; 1061927->1061928; 1061928->1061929; 1061929->1061930; 1061930->1061931; 1061931->1061973; 1061973->1061974; 1061974->1061975; }
1061924,1061925
1061931
1061930
1061925
1061926
1061927
1061928
1061929
1061931
1061973
1061974
1061975
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