This is an automated email from the ASF dual-hosted git repository.
afedulov pushed a commit to branch release-1.20
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.20 by this push:
new 407c3d53e8b [FLINK-36348][test] Fix the Netty shuffle direct memory
test by increase the direct memory of TM
407c3d53e8b is described below
commit 407c3d53e8b1dcaae1bf82598227a47b0340f650
Author: sxnan <suxuanna...@gmail.com>
AuthorDate: Fri Sep 27 17:38:16 2024 +0800
[FLINK-36348][test] Fix the Netty shuffle direct memory test by increase
the direct memory of TM
This closes #25413
---
.../test-scripts/test_netty_shuffle_memory_control.sh | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
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 71be5e1cbca..cad60f2d9b4 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
@@ -23,18 +23,15 @@ TEST=flink-netty-shuffle-memory-control-test
TEST_PROGRAM_NAME=NettyShuffleMemoryControlTestProgram
TEST_PROGRAM_JAR=${END_TO_END_DIR}/$TEST/target/$TEST_PROGRAM_NAME.jar
-set_config_key "taskmanager.memory.flink.size" "512m"
+set_config_key "taskmanager.memory.flink.size" "600m"
set_config_key "taskmanager.memory.network.min" "128m"
set_config_key "taskmanager.memory.network.max" "128m"
# 20 slots per task manager.
set_config_key "taskmanager.numberOfTaskSlots" "20"
-# Sets only one arena per TM for boosting the netty internal memory overhead.
-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"
+# Limits the direct memory to be one chunk (4M * 20) plus some margins.
+set_config_key "taskmanager.memory.framework.off-heap.size" "90m"
# Starts the cluster which includes one TaskManager.
start_cluster
