问答 2023-12-05 来自:开发者社区

Flink CDC sqlserver 对flink版本有特殊要求吗?

Flink CDC中sqlsever cdc时 报Could not initialize class io.debezium.connector.sqlserver.SqlServerConnectorConfig 但是 mongo cdc就正常 代码都差不多 sqlserver 对flink版本有特殊要求吗?

文章 2023-12-04 来自:开发者社区

这个错误可能是由于Flink CDC在处理MySQL和SQL Server之间的数据同步时遇到了问题

这个错误可能是由于Flink CDC在处理MySQL和SQL Server之间的数据同步时遇到了问题。为了解决这个问题,你可以尝试以下方法: 确保你的Flink集群有足够的资源来处理这两个数据库之间的数据同步。如果资源不足,可以考虑增加集群的节点数量或提高每个节点的资源配置。 检查你的Flink CDC配置,确保所有必要的设置都已正确完成。...

问答 2023-12-01 来自:开发者社区

Flink CDC中mysql和sqlserver放在一起跑之后,flink集群报了上面这个错误?

Flink CDC中mysql和sqlserver放在一起跑之后,flink集群报了上面这个错误?

问答 2023-12-01 来自:开发者社区

Flink CDC有同时在flink集群里面,跑mysql+sqlserver的参考代码么?

Flink CDC有同时在flink集群里面,跑mysql+sqlserver的参考代码么?用的是flink-sql方式,但是很奇怪,flink-connector-mysql-cdc-2.2.1.jardebezium-connector-mysql-1.5.4.Final.jarflink-sql-connector-mysql-cdc-2.2.1.jar上面的包少了任何一个,都跑不起来。

问答 2023-11-30 来自:开发者社区

请教下Flink CDC SQL Server用户定义数据类型该怎么处理?

请教下Flink CDC SQL Server用户定义数据类型该怎么处理?目前错误提示IllegalArgumentException: The column "WARD_CODE" is referenced as PRIMARY KEY, but a matching column is not defined in table

问答 2023-11-30 来自:开发者社区

Flink CDC为啥sqlserver的数据更新了,我没有捕捉到u的op呢?

Flink CDC为啥sqlserver的数据更新了,我没有捕捉到u的op呢?之前有遇到过这类问题么?

问答 2023-11-30 来自:开发者社区

Flink CDC中sqlserver里面,源头数据库更新数据之后,吐出来的op是u,还是先d后c?

Flink CDC中sqlserver里面,源头数据库更新数据之后,吐出来的op是u,还是先d后c?

问答 2023-11-30 来自:开发者社区

Flink CDC有没有遇到sqlserver的更新,但是op里面没有d,只有c的问题?

Flink CDC有没有遇到sqlserver的更新,但是op里面没有d,只有c的问题?

问答 2023-11-30 来自:开发者社区

Flink CDC连接SQLServer,这个锁就释放了,有别的处理方法吗?

Flink CDC连接SQLServer,报com.microsoft.sqlserver.jdbc.SQLServerException: 已超过了锁请求超时时段。我是提交了个任务以后发现SQL写错了,然后把任务正常cancel掉,改完再运行,就出现这个问题了我尝试了把flink restart,这个锁就释放了,有别的处理方法吗?

问答 2023-11-30 来自:开发者社区

Flink CDC重新打一个sqlserver+mysql的胖包,这个有教程链接么?

Flink CDC重新打一个sqlserver+mysql的胖包,这个有教程链接么?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注