[hotfix][runtime] Adds missing @GuardedBy annotation

XComp · Nov 27, 2024 · 7c6a641 · 7c6a641
1 parent e64b2fd
commit 7c6a641
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...ntime/src/main/java/org/apache/flink/runtime/leaderelection/StandaloneLeaderElection.java b/...ntime/src/main/java/org/apache/flink/runtime/leaderelection/StandaloneLeaderElection.java
@@ -21,6 +21,7 @@
 import org.apache.flink.util.Preconditions;
 
 import javax.annotation.Nullable;
+import javax.annotation.concurrent.GuardedBy;
 
 import java.util.UUID;
 
@@ -34,7 +35,10 @@ public class StandaloneLeaderElection implements LeaderElection {
     private final Object lock = new Object();
 
     private final UUID sessionID;
-    @Nullable private LeaderContender leaderContender;
+
+    @GuardedBy("lock")
+    @Nullable
+    private LeaderContender leaderContender;
 
     public StandaloneLeaderElection(UUID sessionID) {
         this.sessionID = sessionID;