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