4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-qty-opt-service
application UI
Details for Stage 1342760 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1 s
Locality Level Summary:
Process local: 30
Input Size / Records:
983.0 B / 1
Associated Job Ids:
47303
DAG Visualization
digraph G { id="graph_1342760"; subgraph graph_stage_1342760 { id="graph_stage_1342760"; isCluster="true"; label="Stage 1342760"; 394774 [id="node_394774" labelType="html" label="SQLExecutionRDD [394774] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; subgraph cluster_1039700 { id="cluster_1039700"; isCluster="true"; label="Exchange"; 394769 [id="node_394769" labelType="html" label="ShuffledRowRDD [394769] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039699 { id="cluster_1039699"; isCluster="true"; label="ObjectHashAggregate"; 394770 [id="node_394770" labelType="html" label="MapPartitionsRDD [394770] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039678 { id="cluster_1039678"; isCluster="true"; label="WholeStageCodegen (11)"; 394771 [id="node_394771" labelType="html" label="MapPartitionsRDD [394771] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039662 { id="cluster_1039662"; isCluster="true"; label="DeserializeToObject"; 394772 [id="node_394772" labelType="html" label="MapPartitionsRDD [394772] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039652 { id="cluster_1039652"; isCluster="true"; label="MapPartitions"; 394773 [id="node_394773" labelType="html" label="MapPartitionsRDD [394773] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039745 { id="cluster_1039745"; isCluster="true"; label="mapPartitions"; 394775 [id="node_394775" labelType="html" label="MapPartitionsRDD [394775] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039869 { id="cluster_1039869"; isCluster="true"; label="Scan"; 394805 [id="node_394805" labelType="html" label="MapPartitionsRDD [394805] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039858 { id="cluster_1039858"; isCluster="true"; label="WholeStageCodegen (1)"; 394806 [id="node_394806" labelType="html" label="MapPartitionsRDD [394806] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } subgraph cluster_1039857 { id="cluster_1039857"; isCluster="true"; label="Exchange"; 394807 [id="node_394807" labelType="html" label="MapPartitionsRDD [394807] [Indeterminate]<br>start at FileStorageAdapterImpl.java:598}"]; } } 394769->394770; 394770->394771; 394771->394772; 394772->394773; 394773->394774; 394774->394775; 394775->394805; 394805->394806; 394806->394807; }
394768,394769
394775
394774
394769
394770
394771
394772
394773
394775
394805
394806
394807
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