4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 116511 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
12 s
Locality Level Summary:
Node local: 20; Process local: 17
Shuffle Read Size / Records:
302.0 KiB / 69
Associated Job Ids:
6407
DAG Visualization
digraph G { id="graph_116511"; subgraph graph_stage_116511 { id="graph_stage_116511"; isCluster="true"; label="Stage 116511"; 56301 [id="node_56301" labelType="html" label="SQLExecutionRDD [56301] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; subgraph cluster_146154 { id="cluster_146154"; isCluster="true"; label="Exchange"; 56296 [id="node_56296" labelType="html" label="ShuffledRowRDD [56296] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146153 { id="cluster_146153"; isCluster="true"; label="ObjectHashAggregate"; 56297 [id="node_56297" labelType="html" label="MapPartitionsRDD [56297] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146003 { id="cluster_146003"; isCluster="true"; label="WholeStageCodegen (17)"; 56298 [id="node_56298" labelType="html" label="MapPartitionsRDD [56298] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146002 { id="cluster_146002"; isCluster="true"; label="DeserializeToObject"; 56299 [id="node_56299" labelType="html" label="MapPartitionsRDD [56299] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_145997 { id="cluster_145997"; isCluster="true"; label="MapPartitions"; 56300 [id="node_56300" labelType="html" label="MapPartitionsRDD [56300] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } subgraph cluster_146240 { id="cluster_146240"; isCluster="true"; label="mapPartitions"; 56302 [id="node_56302" labelType="html" label="MapPartitionsRDD [56302] [Cached] [Indeterminate]<br>start at FileStorageAdapterImpl.java:171}"]; } } 56296->56297; 56297->56298; 56298->56299; 56299->56300; 56300->56301; 56301->56302; }
56295,56296
56302
56301
56296
56297
56298
56299
56300
56302
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