lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(launcher): 增加flink的非jvm内存配置

Browse Source
This commit is contained in:
v-zhangjc9
2024-03-20 14:35:07 +08:00
parent 0608fa8344
commit b6865127ca
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
service-launcher/src/main/java/com/lanyuanxiaoyao/service/launcher/ExecutorService.java
View File

@@ -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()));