This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 2b2e29adcbec81cfc90eac9fb816525346c252b7
Author: Xintong Song <tonysong...@gmail.com>
AuthorDate: Tue Feb 23 16:50:15 2021 +0800

    [hotfix][runtime][test] Add missing checks in TaskExecutorProcessUtils.
---
 .../src/main/java/org/apache/flink/configuration/ConfigurationUtils.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
 
b/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
index 81cc2e7..724e752 100755
--- 
a/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
+++ 
b/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java
@@ -210,6 +210,7 @@ public class ConfigurationUtils {
             }
         }
 
+        checkConfigContains(configs, TaskManagerOptions.CPU_CORES.key());
         checkConfigContains(configs, 
TaskManagerOptions.FRAMEWORK_HEAP_MEMORY.key());
         checkConfigContains(configs, 
TaskManagerOptions.FRAMEWORK_OFF_HEAP_MEMORY.key());
         checkConfigContains(configs, 
TaskManagerOptions.TASK_HEAP_MEMORY.key());

Reply via email to