4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 239 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
1.6 min
Locality Level Summary:
Any: 2; Node local: 35
Shuffle Read Size / Records:
774.4 MiB / 15976839
Shuffle Write Size / Records:
751.7 MiB / 15976839
Associated Job Ids:
114
DAG Visualization
digraph G { id="graph_239"; subgraph graph_stage_239 { id="graph_stage_239"; isCluster="true"; label="Stage 239"; subgraph cluster_1351 { id="cluster_1351"; isCluster="true"; label="Exchange"; 508 [id="node_508" labelType="html" label="ShuffledRowRDD [508] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1347 { id="cluster_1347"; isCluster="true"; label="WholeStageCodegen (34)"; 509 [id="node_509" labelType="html" label="MapPartitionsRDD [509] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_1346 { id="cluster_1346"; isCluster="true"; label="Exchange"; 510 [id="node_510" labelType="html" label="MapPartitionsRDD [510] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 508->509; 509->510; }
422,508
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