Flink CDC配置的Managed Memory不生效可能有以下几种原因:
配置项错误:请确保您在Flink配置文件中正确设置了Managed Memory相关的配置项,例如"taskmanager.memory.managed.fraction"和"taskmanager.memory.managed.size"。这些配置项用于指定任务管理器用于管理的内存比例和大小。
集群资源不足:如果您的集群中的可用内存不足以满足配置的Managed Memory需求,那么配置将无法生效。请确保您的集群具有足够的可用内存来支持所需的Managed Memory配置。
其他配置冲突:某些其他配置可能会与Managed Memory配置发生冲突,导致其不生效。请检查您的Flink配置文件中是否存在其他可能导致冲突的配置项,并尝试进行调整或排除冲突。
Flink版本问题:不同的Flink版本可能对Managed Memory的配置方式有所不同。请确保您使用的Flink版本支持您所配置的Managed Memory选项,并且按照相应的文档进行配置。
调下启动参数, 把menagemenory 调小。 -Dtaskmanager.memory.managed.fraction=0.1 ,invoke是来一条处理一条吧,你试试添加个count状态变量累加计数看看是不是一样,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。