4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1333197 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 30
Input Size / Records:
1059.0 B / 1
Shuffle Write Size / Records:
92.0 B / 1
Associated Job Ids:
47106
DAG Visualization
digraph G { id="graph_1333197"; subgraph graph_stage_1333197 { id="graph_stage_1333197"; isCluster="true"; label="Stage 1333197"; 392918 [id="node_392918" labelType="html" label="SQLExecutionRDD [392918] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1034737 { id="cluster_1034737"; isCluster="true"; label="Exchange"; 392913 [id="node_392913" labelType="html" label="ShuffledRowRDD [392913] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034736 { id="cluster_1034736"; isCluster="true"; label="ObjectHashAggregate"; 392914 [id="node_392914" labelType="html" label="MapPartitionsRDD [392914] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034715 { id="cluster_1034715"; isCluster="true"; label="WholeStageCodegen (11)"; 392915 [id="node_392915" labelType="html" label="MapPartitionsRDD [392915] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034699 { id="cluster_1034699"; isCluster="true"; label="DeserializeToObject"; 392916 [id="node_392916" labelType="html" label="MapPartitionsRDD [392916] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034689 { id="cluster_1034689"; isCluster="true"; label="MapPartitions"; 392917 [id="node_392917" labelType="html" label="MapPartitionsRDD [392917] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034782 { id="cluster_1034782"; isCluster="true"; label="mapPartitions"; 392919 [id="node_392919" labelType="html" label="MapPartitionsRDD [392919] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034981 { id="cluster_1034981"; isCluster="true"; label="Scan"; 392967 [id="node_392967" labelType="html" label="MapPartitionsRDD [392967] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034970 { id="cluster_1034970"; isCluster="true"; label="WholeStageCodegen (1)"; 392968 [id="node_392968" labelType="html" label="MapPartitionsRDD [392968] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1034969 { id="cluster_1034969"; isCluster="true"; label="Exchange"; 392969 [id="node_392969" labelType="html" label="MapPartitionsRDD [392969] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 392913->392914; 392914->392915; 392915->392916; 392916->392917; 392917->392918; 392918->392919; 392919->392967; 392967->392968; 392968->392969; }
392912,392913
392919
392918
392913
392914
392915
392916
392917
392919
392967
392968
392969
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