4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 3725308 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
44 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:
127219
DAG Visualization
digraph G { id="graph_3725308"; subgraph graph_stage_3725308 { id="graph_stage_3725308"; isCluster="true"; label="Stage 3725308"; 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_2796377 { id="cluster_2796377"; isCluster="true"; label="Scan"; 1061961 [id="node_1061961" labelType="html" label="MapPartitionsRDD [1061961] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796366 { id="cluster_2796366"; isCluster="true"; label="WholeStageCodegen (1)"; 1061962 [id="node_1061962" labelType="html" label="MapPartitionsRDD [1061962] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_2796365 { id="cluster_2796365"; isCluster="true"; label="Exchange"; 1061963 [id="node_1061963" labelType="html" label="MapPartitionsRDD [1061963] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 1061925->1061926; 1061926->1061927; 1061927->1061928; 1061928->1061929; 1061929->1061930; 1061930->1061931; 1061931->1061961; 1061961->1061962; 1061962->1061963; }
1061924,1061925
1061931
1061930
1061925
1061926
1061927
1061928
1061929
1061931
1061961
1061962
1061963
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