4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 115997 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
11 s
Locality Level Summary:
Node local: 20; Process local: 17
Shuffle Read Size / Records:
304.3 KiB / 69
Associated Job Ids:
6386
DAG Visualization
digraph G { id="graph_115997"; subgraph graph_stage_115997 { id="graph_stage_115997"; isCluster="true"; label="Stage 115997"; 56037 [id="node_56037" labelType="html" label="SQLExecutionRDD [56037] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_145533 { id="cluster_145533"; isCluster="true"; label="Exchange"; 56032 [id="node_56032" labelType="html" label="ShuffledRowRDD [56032] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145532 { id="cluster_145532"; isCluster="true"; label="ObjectHashAggregate"; 56033 [id="node_56033" labelType="html" label="MapPartitionsRDD [56033] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145382 { id="cluster_145382"; isCluster="true"; label="WholeStageCodegen (17)"; 56034 [id="node_56034" labelType="html" label="MapPartitionsRDD [56034] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145381 { id="cluster_145381"; isCluster="true"; label="DeserializeToObject"; 56035 [id="node_56035" labelType="html" label="MapPartitionsRDD [56035] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145376 { id="cluster_145376"; isCluster="true"; label="MapPartitions"; 56036 [id="node_56036" labelType="html" label="MapPartitionsRDD [56036] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145619 { id="cluster_145619"; isCluster="true"; label="mapPartitions"; 56038 [id="node_56038" labelType="html" label="MapPartitionsRDD [56038] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56032->56033; 56033->56034; 56034->56035; 56035->56036; 56036->56037; 56037->56038; }
56031,56032
56038
56037
56032
56033
56034
56035
56036
56038
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