From b2a98e60ad0ecb695a6178d6130cda84553b8ff2 Mon Sep 17 00:00:00 2001 From: Ferenc Csaky Date: Fri, 10 Jan 2025 15:45:42 +0100 Subject: [PATCH] [FLINK-37100][tests] Fix test_netty_shuffle_memory_control.sh in CI for JDK11+ --- .../test-scripts/test_netty_shuffle_memory_control.sh | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-end-to-end-tests/test-scripts/test_netty_shuffle_memory_control.sh b/flink-end-to-end-tests/test-scripts/test_netty_shuffle_memory_control.sh index 71be5e1cbcadbe..1fde651fb54de9 100755 --- a/flink-end-to-end-tests/test-scripts/test_netty_shuffle_memory_control.sh +++ b/flink-end-to-end-tests/test-scripts/test_netty_shuffle_memory_control.sh @@ -36,6 +36,10 @@ set_config_key "taskmanager.network.netty.num-arenas" "1" # Limits the direct memory to be one chunk (4M) plus some margins. set_config_key "taskmanager.memory.framework.off-heap.size" "7m" +# Enable reflection for Nett4, which reduces its memory footprint on JDK11+, +# so the allocated memory originally assumed for Netty3 will still be sufficient. +set_config_key "env.java.opts.taskmanager" "-Dorg.apache.flink.shaded.netty4.io.netty.tryReflectionSetAccessible=true" + # Starts the cluster which includes one TaskManager. start_cluster