Flink CDC中都放了,mysqlcdc也是放了这些,没有遇到这个问题?

"Flink CDC中都放了,mysqlcdc也是放了这些,没有遇到这个问题?image.png
"

展开
收起
真的很搞笑 2023-11-22 07:14:23 81 分享 版权
2 条回答
写回答
取消 提交回答
  • 估计包冲突,把debezium的包删了,然后flink写入sql-server只能通过jdbc连接器,image.png
    这些包其实都不需要,然后你这还有不同版本的flink对应的包,这不适合,此回答整理自钉群“Flink CDC 社区”

    2023-11-22 11:11:37
    赞同 展开评论
  • 看起来你正在运行一个Flink作业,但是这个作业的CPU使用率非常高。这可能是因为你的作业在处理大量的数据,或者是因为你的作业有一些性能瓶颈。

    首先,你可以尝试优化你的作业。这可能包括优化你的数据处理逻辑,例如减少不必要的计算,或者优化你的数据处理流程,例如使用更有效的数据结构或者算法。

    其次,你可以尝试优化你的Flink集群。这可能包括调整你的Flink集群的配置,例如增加更多的资源(例如CPU和内存),或者调整你的Flink集群的并行度。

    最后,你可以尝试优化你的数据源。这可能包括优化你的数据源的性能,例如优化你的数据库查询,或者优化你的数据源的数据结构。

    2023-11-22 10:20:03
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理