4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 1191 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
2 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
6.6 KiB / 87
Shuffle Write Size / Records:
15.9 KiB / 390
Associated Job Ids:
566
DAG Visualization
digraph G { id="graph_1191"; subgraph graph_stage_1191 { id="graph_stage_1191"; isCluster="true"; label="Stage 1191"; subgraph cluster_9797 { id="cluster_9797"; isCluster="true"; label="AQEShuffleRead"; 3072 [id="node_3072" labelType="html" label="ShuffledRowRDD [3072] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9775 { id="cluster_9775"; isCluster="true"; label="WholeStageCodegen (291)"; 3079 [id="node_3079" labelType="html" label="MapPartitionsRDD [3079] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9773 { id="cluster_9773"; isCluster="true"; label="Generate"; 3080 [id="node_3080" labelType="html" label="MapPartitionsRDD [3080] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9771 { id="cluster_9771"; isCluster="true"; label="ObjectHashAggregate"; 3081 [id="node_3081" labelType="html" label="MapPartitionsRDD [3081] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9768 { id="cluster_9768"; isCluster="true"; label="ObjectHashAggregate"; 3082 [id="node_3082" labelType="html" label="MapPartitionsRDD [3082] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9758 { id="cluster_9758"; isCluster="true"; label="WholeStageCodegen (292)"; 3083 [id="node_3083" labelType="html" label="MapPartitionsRDD [3083] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_9757 { id="cluster_9757"; isCluster="true"; label="Exchange"; 3084 [id="node_3084" labelType="html" label="MapPartitionsRDD [3084] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 3072->3079; 3079->3080; 3080->3081; 3081->3082; 3082->3083; 3083->3084; }
3070,3072
Event Timeline
Enable zooming
Tasks: 1. 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