This is an automated email from the ASF dual-hosted git repository. Abacn pushed a commit to branch try-fix in repository https://gitbox.apache.org/repos/asf/beam.git
commit c6f125aa9f6b9b343aaca23de03a00e7f3479a72 Author: Yi Hu <[email protected]> AuthorDate: Thu Aug 27 11:02:28 2026 -0400 Try fix miniCluster jar --- 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
