我正在尝试将Flink从1.8.2升级到1.10.3。1.8.2与配置配合良好
jobmanager.heap.mb: ${jobManagerHeapSize}
taskmanager.heap.mb: ${jobManagerHeapSize}
taskmanager.memory.preallocate: false
修改为
jobmanager.heap.mb: ${jobManagerHeapSize}
taskmanager.memory.process.size: 1024
然后我得到以下错误
Caused by: org.apache.flink.configuration.IllegalConfigurationException: The required configuration option Key: 'taskmanager.cpu.cores' , default: null (fallback keys: []) is not set
at org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils.checkConfigOptionIsSet(TaskExecutorResourceUtils.java:90)
我尝试添加核心，然后得到错误to provide taskmanager.memory.task.heap.size和taskmanager.memory.managed.size。根据文档，仅taskmanager.memory.process.size就足够了，将计算其他内存选项。这里有什么问题。
感谢您的帮助
问题可能是1024字节的内存不足，无法用于任务管理器。您可能打算配置1024m，但这可能还不够——默认配置指定1728m。