This is an automated email from the ASF dual-hosted git repository. Amar3tto pushed a commit to branch portablejar-flink in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5949439eaa13a728b8e430817e85eb90b6ad7933 Author: Vitaly Terentyev <[email protected]> AuthorDate: Thu Aug 27 12:38:49 2026 +0400 Stabilize workflow --- .github/workflows/beam_PostCommit_PortableJar_Flink.yml | 1 + runners/flink/job-server/flink_job_server.gradle | 5 ++++- runners/portability/test_flink_uber_jar.sh | 12 +++++++++++- 3 files changed, 16 insertions(+), 2 deletions(-) diff --git a/.github/workflows/beam_PostCommit_PortableJar_Flink.yml b/.github/workflows/beam_PostCommit_PortableJar_Flink.yml index 4d3571eecff..06e95bc6659 100644 --- a/.github/workflows/beam_PostCommit_PortableJar_Flink.yml +++ b/.github/workflows/beam_PostCommit_PortableJar_Flink.yml @@ -76,6 +76,7 @@ jobs: uses: ./.github/actions/setup-environment-action with: python-version: default + java-version: '17' - name: run testPipelineJarFlinkRunner script env: CLOUDSDK_CONFIG: ${{ env.KUBELET_GCLOUD_CONFIG_PATH}} diff --git a/runners/flink/job-server/flink_job_server.gradle b/runners/flink/job-server/flink_job_server.gradle index 46b1b5a607f..997bae5d293 100644 --- a/runners/flink/job-server/flink_job_server.gradle +++ b/runners/flink/job-server/flink_job_server.gradle @@ -351,7 +351,10 @@ tasks.register("miniCluster", Jar) { exclude "**/PortablePipelineJarUtils*" } 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
