Caused by: java.util.concurrent.CompletionException: java.util.concurrent.CompletionException: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire the minimum required resources.
at org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:226)
办理:修改flink的配置文件 ,目次是 flink-1.18.0/conf/中flink-conf-yaml的jobmanager.memory.process.size和taskmanager.memory.flink.size。
如修改为
jobmanager.memory.process.size: 5600m
taskmanager.memory.flink.size: 6280m
然后重启flink服务 ./bin/stop-cluster.sh,重启同步任务。
注意:实际修改后还是报错,发现配置前面多了个空格⊙﹏⊙,删掉后重启服务成功。。配置时要仔细查抄。
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |