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
The following commit(s) were added to refs/heads/portablejar-flink by this push:
new c1118f8713f Add-opens
c1118f8713f is described below
commit c1118f8713f2af007644a0c913e7bed0bef06522
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Thu Aug 27 16:04:31 2026 +0400
Add-opens
---
runners/portability/test_flink_uber_jar.sh | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
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
