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;