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