4.0.1
Jobs
Stages
Storage
Environment
Executors
SQL / DataFrame
Structured Streaming
crp-order-quantity-kpi-service
application UI
Details for Stage 105840 (Attempt 0)
Resource Profile Id:
0
Total Time Across All Tasks:
0.4 s
Locality Level Summary:
Node local: 1
Shuffle Read Size / Records:
2.5 KiB / 24
Shuffle Write Size / Records:
3.5 KiB / 25
Associated Job Ids:
5882
DAG Visualization
digraph G { id="graph_105840"; subgraph graph_stage_105840 { id="graph_stage_105840"; isCluster="true"; label="Stage 105840"; subgraph cluster_132783 { id="cluster_132783"; isCluster="true"; label="AQEShuffleRead"; 50895 [id="node_50895" labelType="html" label="ShuffledRowRDD [50895] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_132754 { id="cluster_132754"; isCluster="true"; label="WholeStageCodegen (130)"; 50897 [id="node_50897" labelType="html" label="MapPartitionsRDD [50897] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_132753 { id="cluster_132753"; isCluster="true"; label="Generate"; 50900 [id="node_50900" labelType="html" label="MapPartitionsRDD [50900] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_132752 { id="cluster_132752"; isCluster="true"; label="ObjectHashAggregate"; 50902 [id="node_50902" labelType="html" label="MapPartitionsRDD [50902] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_132751 { id="cluster_132751"; isCluster="true"; label="ObjectHashAggregate"; 50903 [id="node_50903" labelType="html" label="MapPartitionsRDD [50903] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_132745 { id="cluster_132745"; isCluster="true"; label="WholeStageCodegen (131)"; 50905 [id="node_50905" labelType="html" label="MapPartitionsRDD [50905] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } subgraph cluster_132744 { id="cluster_132744"; isCluster="true"; label="Exchange"; 50907 [id="node_50907" labelType="html" label="MapPartitionsRDD [50907] [Unordered]<br>$anonfun$withThreadLocalCaptured$2 at <unknown>:0}"]; } } 50895->50897; 50897->50900; 50900->50902; 50902->50903; 50903->50905; 50905->50907; }
50893,50895
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