4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 115644 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
12 s
Locality Level Summary:
Node local: 22; Process local: 15
Shuffle Read Size / Records:
488.1 KiB / 179
Associated Job Ids:
6364
DAG Visualization
digraph G { id="graph_115644"; subgraph graph_stage_115644 { id="graph_stage_115644"; isCluster="true"; label="Stage 115644"; 55769 [id="node_55769" labelType="html" label="SQLExecutionRDD [55769] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_144901 { id="cluster_144901"; isCluster="true"; label="Exchange"; 55764 [id="node_55764" labelType="html" label="ShuffledRowRDD [55764] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144900 { id="cluster_144900"; isCluster="true"; label="ObjectHashAggregate"; 55765 [id="node_55765" labelType="html" label="MapPartitionsRDD [55765] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144750 { id="cluster_144750"; isCluster="true"; label="WholeStageCodegen (17)"; 55766 [id="node_55766" labelType="html" label="MapPartitionsRDD [55766] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144749 { id="cluster_144749"; isCluster="true"; label="DeserializeToObject"; 55767 [id="node_55767" labelType="html" label="MapPartitionsRDD [55767] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144744 { id="cluster_144744"; isCluster="true"; label="MapPartitions"; 55768 [id="node_55768" labelType="html" label="MapPartitionsRDD [55768] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_144987 { id="cluster_144987"; isCluster="true"; label="mapPartitions"; 55770 [id="node_55770" labelType="html" label="MapPartitionsRDD [55770] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 55764->55765; 55765->55766; 55766->55767; 55767->55768; 55768->55769; 55769->55770; }
55763,55764
55770
55769
55764
55765
55766
55767
55768
55770
Event Timeline
Enable zooming
Tasks: 37. 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