从你提供的图片中,可以看出 Flink CDC 的 GC 分配确实失败了。错误信息如下:
java.lang.OutOfMemoryError: GC overhead limit exceeded
这表示 Java 虚拟机 (JVM) 在尝试进行垃圾回收时遇到了问题,并且它已达到其 GC 开销限制。这意味着 JVM 花费了过多的时间进行垃圾回收,以至于它无法及时释放内存来满足新的对象分配。
可能的原因:
Record
、Event
和 SourceFunction
实例。如果这些对象没有被正确释放,它们就会在堆中累积,导致 GC 压力。解决方案:
其他提示:
示例 JVM 配置:
-Xmx8g
-Xms8g
-XX:MaxGCPauseMillis=100
-XX:+UseG1GC
请注意,这些设置只是建议,最佳配置可能因具体的工作负载而异。
不是,Flink CDC GC 分配成功了。container e111675072188829000501000002 是Flink CDC GC 分配的一个容器,表示Flink CDC GC 分配成功了。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。