Fixes test

XComp · Nov 25, 2024 · 9b4e87e · 9b4e87e
1 parent 270751a
commit 9b4e87e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...time/src/test/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionTest.java b/...time/src/test/java/org/apache/flink/runtime/leaderelection/DefaultLeaderElectionTest.java
@@ -186,7 +186,9 @@ void testRunAsLeader() throws Exception {
                     .isEqualTo(serviceRunAsLeaderFuture);
             assertThat(componentIdRef).hasValue(DEFAULT_TEST_COMPONENT_ID);
             assertThat(leaderSessionIDRef).hasValue(expectedLeaderSessionID);
-            assertThat(callbackRef).as("The callback wasn't altered.").isSameAs(actualCallback);
+            assertThat(callbackRef.get())
+                    .as("The callback wasn't altered.")
+                    .isSameAs(actualCallback);
         }
     }