This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new ea8905a85b6 [FLINK-39815][tests] Mark SecurityManager related tests 
with `FailsOnJava25`
ea8905a85b6 is described below

commit ea8905a85b6fbb2476c7126d477de7ffc9cd375f
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Mon Jun 1 21:01:06 2026 +0200

    [FLINK-39815][tests] Mark SecurityManager related tests with `FailsOnJava25`
---
 .../slotmanager/AbstractFineGrainedSlotManagerITCase.java              | 3 +++
 .../java/org/apache/flink/runtime/util/FlinkSecurityManagerITCase.java | 2 ++
 .../apache/flink/streaming/runtime/tasks/StreamTaskSystemExitTest.java | 2 ++
 3 files changed, 7 insertions(+)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/AbstractFineGrainedSlotManagerITCase.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/AbstractFineGrainedSlotManagerITCase.java
index c7f37427aaf..48a938e0bc6 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/AbstractFineGrainedSlotManagerITCase.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/AbstractFineGrainedSlotManagerITCase.java
@@ -38,6 +38,7 @@ import 
org.apache.flink.runtime.taskexecutor.exceptions.SlotAllocationException;
 import org.apache.flink.runtime.testutils.SystemExitTrackingSecurityManager;
 import org.apache.flink.util.function.FunctionUtils;
 
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 
 import java.util.ArrayList;
@@ -722,6 +723,7 @@ abstract class AbstractFineGrainedSlotManagerITCase extends 
FineGrainedSlotManag
      * Verify that the ack of request slot form unregistered task manager will 
not cause system
      * breakdown.
      */
+    @Tag("org.apache.flink.testutils.junit.FailsOnJava25")
     @Test
     void testAllocationUpdatesIgnoredIfTaskExecutorUnregistered() throws 
Exception {
         final CompletableFuture<Acknowledge> slotRequestFuture = new 
CompletableFuture<>();
@@ -782,6 +784,7 @@ abstract class AbstractFineGrainedSlotManagerITCase extends 
FineGrainedSlotManag
         System.setSecurityManager(null);
     }
 
+    @Tag("org.apache.flink.testutils.junit.FailsOnJava25")
     @Test
     void testAllocationUpdatesIgnoredIfSlotMarkedAsAllocatedAfterSlotReport() 
throws Exception {
         final CompletableFuture<AllocationID> allocationIdFuture = new 
CompletableFuture<>();
diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/util/FlinkSecurityManagerITCase.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/util/FlinkSecurityManagerITCase.java
index d46727b2d29..94b2835b4b3 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/util/FlinkSecurityManagerITCase.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/util/FlinkSecurityManagerITCase.java
@@ -25,12 +25,14 @@ import org.apache.flink.runtime.testutils.TestJvmProcess;
 import org.apache.flink.util.OperatingSystem;
 
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assumptions.assumeThat;
 
 /** Integration tests for the {@link FlinkSecurityManager}. */
+@Tag("org.apache.flink.testutils.junit.FailsOnJava25")
 class FlinkSecurityManagerITCase {
 
     @BeforeEach
diff --git 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskSystemExitTest.java
 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskSystemExitTest.java
index 5f254a9ae57..e7eb44f4c36 100644
--- 
a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskSystemExitTest.java
+++ 
b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskSystemExitTest.java
@@ -69,6 +69,7 @@ import org.apache.flink.util.concurrent.Executors;
 
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Tag;
 import org.junit.jupiter.api.Test;
 
 import java.util.Collections;
@@ -83,6 +84,7 @@ import static org.mockito.Mockito.mock;
  * exit is enabled inside relevant methods that can call user-defined 
functions in {@code
  * StreamTask}.
  */
+@Tag("org.apache.flink.testutils.junit.FailsOnJava25")
 class StreamTaskSystemExitTest {
     private static final int TEST_EXIT_CODE = 123;
     private SecurityManager originalSecurityManager;

Reply via email to