根据提供的错误信息,看起来是在 Flink CDC 的配置文件中存在一个问题,具体是与 jobmanager.memory.flink.size 相关的配置项。
根据错误信息中的片段,配置项的值似乎被截断,并且包含了一些不正确的字符,如 res. 197.168tratanyrest.address, 192.168.11.249t,6123m t y ftn wmory st0.11.249eg3lconfiotat process Memory size (keyt ojobmanegeretiegacEithefailed:erProcessUtils.java:78)sUtils .processSpecFromt0eUti nand00hIvatsva6Memory size (Key: jobmanager.memory.flink.size"。
解决这个问题的方法是检查 Flink CDC 的配置文件,特别是 jobmanager.memory.flink.size 这个配置项,确保其格式正确且值被正确设置。确保配置项的值只包含合法的字符,并且没有被截断或包含其他不相关的字符。
"测试用单机配置基本不用动,从单机开始吧 https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/deployment/resource-providers/standalone/overview/
配置项有现成的例子,你检查下单位是不是乱写的。此回答整理至钉群“Flink CDC 社区”。"
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。