如果Flink CDC可以正常打印输出,但是数据无法正确sink到目标端,可能的原因包括:
taskmanager.heap.size 和 jobmanager.heap.size 这两个参数你改改看 ,此回答整理自钉群“Flink CDC 社区”
根据您提供的截图内容,看起来像是Flink CDC任务运行时遇到了一个问题,具体来说是在执行某个操作后触发了一个警告级别的提示:“Memory usage [12%] is too high to satisfy all of the requests”。这意味着Flink的任务试图使用的内存量超过了实际可利用的数量,从而可能导致性能下降甚至失败。
要解决这个问题,您可以考虑以下几个方面:
对于第二个问题,从输出结果来看,似乎是一个Python脚本的交互式命令行界面。在这个界面上,你可以看到一些变量赋值的结果,比如 aaa:20> {"name": "2", "id": 2, "uuuu": "2"}
这一行显示了字典类型的一个键值对结构。如果你想要查看其他的内容,可以在输入框中继续输入相应的指令即可。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。