From 2e6b680e94a25d6ecb53fccce55458967e896c2a Mon Sep 17 00:00:00 2001 From: aIbrahiim Date: Mon, 13 Jul 2026 19:42:40 +0300 Subject: [PATCH 1/2] add jdkAddOpenModules for Dataflow V2 --- .github/trigger_files/beam_PostCommit_Java_DataflowV2.json | 2 +- runners/google-cloud-dataflow-java/build.gradle | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json b/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json index d0d502569834..22c1b0fe7ac4 100644 --- a/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json +++ b/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json @@ -1,4 +1,4 @@ { - "modification": 7, + "modification": 8, "https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface" } diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle index d5b0d9e82363..218b7f344534 100644 --- a/runners/google-cloud-dataflow-java/build.gradle +++ b/runners/google-cloud-dataflow-java/build.gradle @@ -189,7 +189,8 @@ def runnerV2CommonPipelineOptions = [ "--experiments=use_unified_worker,use_runner_v2", "--firestoreDb=${firestoreDb}", "--usePublicIps=false", - "--experiments=enable_lineage" + "--experiments=enable_lineage", + "--jdkAddOpenModules=java.base/java.nio=ALL-UNNAMED", ] def runnerV2PipelineOptions = runnerV2CommonPipelineOptions + [ From 5b4b2f19283f013098a182fdfa9e33d24197a929 Mon Sep 17 00:00:00 2001 From: aIbrahiim Date: Tue, 14 Jul 2026 21:28:59 +0300 Subject: [PATCH 2/2] add arrow java.nio add opens to java sdk container options --- .../trigger_files/beam_PostCommit_Java_DataflowV2.json | 2 +- runners/google-cloud-dataflow-java/build.gradle | 3 +-- sdks/java/container/common.gradle | 1 + sdks/java/container/java17/option-arrow.json | 9 +++++++++ sdks/java/container/java21/option-arrow.json | 9 +++++++++ sdks/java/container/java25/option-arrow.json | 9 +++++++++ 6 files changed, 30 insertions(+), 3 deletions(-) create mode 100644 sdks/java/container/java17/option-arrow.json create mode 100644 sdks/java/container/java21/option-arrow.json create mode 100644 sdks/java/container/java25/option-arrow.json diff --git a/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json b/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json index 22c1b0fe7ac4..c4a6954cecb7 100644 --- a/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json +++ b/.github/trigger_files/beam_PostCommit_Java_DataflowV2.json @@ -1,4 +1,4 @@ { - "modification": 8, + "modification": 9, "https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface" } diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle index 218b7f344534..d5b0d9e82363 100644 --- a/runners/google-cloud-dataflow-java/build.gradle +++ b/runners/google-cloud-dataflow-java/build.gradle @@ -189,8 +189,7 @@ def runnerV2CommonPipelineOptions = [ "--experiments=use_unified_worker,use_runner_v2", "--firestoreDb=${firestoreDb}", "--usePublicIps=false", - "--experiments=enable_lineage", - "--jdkAddOpenModules=java.base/java.nio=ALL-UNNAMED", + "--experiments=enable_lineage" ] def runnerV2PipelineOptions = runnerV2CommonPipelineOptions + [ diff --git a/sdks/java/container/common.gradle b/sdks/java/container/common.gradle index c81a33827bef..5b2322f61a35 100644 --- a/sdks/java/container/common.gradle +++ b/sdks/java/container/common.gradle @@ -83,6 +83,7 @@ task copyGolangLicenses(type: Copy) { task copyJdkOptions(type: Copy) { from "option-jamm.json" + from "option-arrow.json" from "java${imageJavaVersion}-security.properties" from "option-java${imageJavaVersion}-security.json" into "build/target/options" diff --git a/sdks/java/container/java17/option-arrow.json b/sdks/java/container/java17/option-arrow.json new file mode 100644 index 000000000000..a22b46ac1f78 --- /dev/null +++ b/sdks/java/container/java17/option-arrow.json @@ -0,0 +1,9 @@ +{ + "name": "arrow", + "enabled": true, + "options": { + "java_arguments": [ + "--add-opens=java.base/java.nio=ALL-UNNAMED" + ] + } +} diff --git a/sdks/java/container/java21/option-arrow.json b/sdks/java/container/java21/option-arrow.json new file mode 100644 index 000000000000..a22b46ac1f78 --- /dev/null +++ b/sdks/java/container/java21/option-arrow.json @@ -0,0 +1,9 @@ +{ + "name": "arrow", + "enabled": true, + "options": { + "java_arguments": [ + "--add-opens=java.base/java.nio=ALL-UNNAMED" + ] + } +} diff --git a/sdks/java/container/java25/option-arrow.json b/sdks/java/container/java25/option-arrow.json new file mode 100644 index 000000000000..a22b46ac1f78 --- /dev/null +++ b/sdks/java/container/java25/option-arrow.json @@ -0,0 +1,9 @@ +{ + "name": "arrow", + "enabled": true, + "options": { + "java_arguments": [ + "--add-opens=java.base/java.nio=ALL-UNNAMED" + ] + } +}