4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 102562 (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:
308.7 KiB / 81
Associated Job Ids:
5696
DAG Visualization
digraph G { id="graph_102562"; subgraph graph_stage_102562 { id="graph_stage_102562"; isCluster="true"; label="Stage 102562"; 49293 [id="node_49293" labelType="html" label="SQLExecutionRDD [49293] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_128638 { id="cluster_128638"; isCluster="true"; label="Exchange"; 49288 [id="node_49288" labelType="html" label="ShuffledRowRDD [49288] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128637 { id="cluster_128637"; isCluster="true"; label="ObjectHashAggregate"; 49289 [id="node_49289" labelType="html" label="MapPartitionsRDD [49289] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128487 { id="cluster_128487"; isCluster="true"; label="WholeStageCodegen (17)"; 49290 [id="node_49290" labelType="html" label="MapPartitionsRDD [49290] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128486 { id="cluster_128486"; isCluster="true"; label="DeserializeToObject"; 49291 [id="node_49291" labelType="html" label="MapPartitionsRDD [49291] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128481 { id="cluster_128481"; isCluster="true"; label="MapPartitions"; 49292 [id="node_49292" labelType="html" label="MapPartitionsRDD [49292] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_128724 { id="cluster_128724"; isCluster="true"; label="mapPartitions"; 49294 [id="node_49294" labelType="html" label="MapPartitionsRDD [49294] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49288->49289; 49289->49290; 49290->49291; 49291->49292; 49292->49293; 49293->49294; }
49287,49288
49294
49293
49288
49289
49290
49291
49292
49294
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