4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 102914 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Node local: 21; Process local: 16
Shuffle Read Size / Records:
160.4 KiB / 58
Associated Job Ids:
5717
DAG Visualization
digraph G { id="graph_102914"; subgraph graph_stage_102914 { id="graph_stage_102914"; isCluster="true"; label="Stage 102914"; 49557 [id="node_49557" labelType="html" label="SQLExecutionRDD [49557] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_129259 { id="cluster_129259"; isCluster="true"; label="Exchange"; 49552 [id="node_49552" labelType="html" label="ShuffledRowRDD [49552] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129258 { id="cluster_129258"; isCluster="true"; label="ObjectHashAggregate"; 49553 [id="node_49553" labelType="html" label="MapPartitionsRDD [49553] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129108 { id="cluster_129108"; isCluster="true"; label="WholeStageCodegen (17)"; 49554 [id="node_49554" labelType="html" label="MapPartitionsRDD [49554] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129107 { id="cluster_129107"; isCluster="true"; label="DeserializeToObject"; 49555 [id="node_49555" labelType="html" label="MapPartitionsRDD [49555] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129102 { id="cluster_129102"; isCluster="true"; label="MapPartitions"; 49556 [id="node_49556" labelType="html" label="MapPartitionsRDD [49556] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_129345 { id="cluster_129345"; isCluster="true"; label="mapPartitions"; 49558 [id="node_49558" labelType="html" label="MapPartitionsRDD [49558] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 49552->49553; 49553->49554; 49554->49555; 49555->49556; 49556->49557; 49557->49558; }
49551,49552
49558
49557
49552
49553
49554
49555
49556
49558
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