From b6865127ca80119702b7f6e7ba72c0eda97c8288 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Wed, 20 Mar 2024 14:35:07 +0800 Subject: [PATCH] =?UTF-8?q?refactor(launcher):=20=E5=A2=9E=E5=8A=A0flink?= =?UTF-8?q?=E7=9A=84=E9=9D=9Ejvm=E5=86=85=E5=AD=98=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/lanyuanxiaoyao/service/launcher/ExecutorService.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java b/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java index a1c0fad..ca387fb 100644 --- a/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java +++ b/service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java @@ -307,6 +307,9 @@ public class ExecutorService { configuration.set(TaskManagerOptions.TOTAL_FLINK_MEMORY, taskMemorySize); configuration.set(TaskManagerOptions.MANAGED_MEMORY_SIZE, MemorySize.parse("0m")); + configuration.set(TaskManagerOptions.TASK_OFF_HEAP_MEMORY, MemorySize.parse("128m")); + configuration.set(TaskManagerOptions.FRAMEWORK_OFF_HEAP_MEMORY, MemorySize.parse("512m")); + configuration.setInteger(TaskManagerOptions.NUM_TASK_SLOTS, 10); configuration.setString(YarnConfigOptions.APPLICATION_NAME, NameHelper.compactionJobName(flinkJob.getId(), tableMeta.getAlias()));