(beam) branch master updated: Try fix miniCluster jar (#39912)

[yhu]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new a057f722cda Try fix miniCluster jar (#39912)
a057f722cda is described below

commit a057f722cda85b197ede16c2f53c47675ddde330
Author: Yi Hu <ya...@google.com>
AuthorDate: Fri Aug 28 08:56:21 2026 -0400

    Try fix miniCluster jar (#39912)
---
 runners/flink/job-server/flink_job_server.gradle |  8 +++++++-
 runners/portability/test_flink_uber_jar.sh       | 12 +++++++++++-
 2 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/runners/flink/job-server/flink_job_server.gradle 
b/runners/flink/job-server/flink_job_server.gradle
index 46b1b5a607f..6f39b67abf7 100644
--- a/runners/flink/job-server/flink_job_server.gradle
+++ b/runners/flink/job-server/flink_job_server.gradle
@@ -350,8 +350,14 @@ tasks.register("miniCluster", Jar) {
     exclude "**/FlinkPipelineRunner*"
     exclude "**/PortablePipelineJarUtils*"
   }
+  shadowJar {
+    exclude 'META-INF/services/java.net.spi.InetAddressResolverProvider'
+  }
   manifest {
-    attributes('Main-Class': 
'org.apache.beam.runners.flink.FlinkMiniClusterEntryPoint')
+    attributes([
+        'Main-Class': 
'org.apache.beam.runners.flink.FlinkMiniClusterEntryPoint',
+        'Multi-Release': 'true'
+    ])
   }
   zip64 true // jar needs to contain more than 65535 files
 }
diff --git a/runners/portability/test_flink_uber_jar.sh 
b/runners/portability/test_flink_uber_jar.sh
index d073de4b91e..83b96d377c6 100755
--- a/runners/portability/test_flink_uber_jar.sh
+++ b/runners/portability/test_flink_uber_jar.sh
@@ -98,7 +98,17 @@ s.close()
 FLINK_PORT=$(python -c "$SOCKET_SCRIPT")
 
 echo "Starting Flink mini cluster listening on port $FLINK_PORT"
-java -Dorg.slf4j.simpleLogger.defaultLogLevel=warn -jar 
"$FLINK_MINI_CLUSTER_JAR" --rest-port "$FLINK_PORT" --rest-bind-address 
localhost &
+java \
+  --add-opens=java.base/sun.nio.ch=ALL-UNNAMED \
+  --add-opens=java.base/java.nio=ALL-UNNAMED \
+  --add-opens=java.base/java.util=ALL-UNNAMED \
+  --add-opens=java.base/java.lang.invoke=ALL-UNNAMED \
+  --add-opens=java.base/java.lang=ALL-UNNAMED \
+  -Djava.security.manager=allow \
+  -Dorg.slf4j.simpleLogger.defaultLogLevel=warn \
+  -jar "$FLINK_MINI_CLUSTER_JAR" \
+  --rest-port "$FLINK_PORT" \
+  --rest-bind-address localhost &
 
 PIPELINE_PY="
 import apache_beam as beam