(flink) branch master updated: [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest`

[snuyanzin]

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 176939632f5 [FLINK-39773][tests] Use random ports in 
`ClusterEntryPointTest`
176939632f5 is described below

commit 176939632f520633ccdec653b121b503e77bd6d1
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Wed May 27 22:31:58 2026 +0200

    [FLINK-39773][tests] Use random ports in `ClusterEntryPointTest`
---
 .../org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java
index c5858a97308..101ee5c6f5a 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointTest.java
@@ -22,6 +22,7 @@ import org.apache.flink.configuration.ClusterOptions;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.IllegalConfigurationException;
 import org.apache.flink.configuration.JobManagerOptions;
+import org.apache.flink.configuration.RestOptions;
 import org.apache.flink.configuration.SchedulerExecutionMode;
 import org.apache.flink.runtime.clusterframework.ApplicationStatus;
 import org.apache.flink.runtime.clusterframework.types.ResourceID;
@@ -93,6 +94,8 @@ public class ClusterEntrypointTest extends TestLogger {
     @Before
     public void before() {
         flinkConfig = new Configuration();
+        flinkConfig.set(RestOptions.BIND_PORT, "0");
+        flinkConfig.set(JobManagerOptions.PORT, 0);
         ExceptionThrowingDelegationTokenProvider.reset();
         ExceptionThrowingDelegationTokenReceiver.reset();
     }