dbz用connector入hana报错Invalid Java object for schema type INT64: class java.util.Long for field “null“

最近需要将用户的mysql数据实时导入到hana中。

方案一为：mysql-cdc---->debezium-source-connector---->kafka----->debezium-sink-connector---->hana

方案一执行过程中，由于mysql的表中有字段类型为：datatime, 默认值为CURRENT_TIMESTAMP。经过测试验证，该时间字段只要加上默认值，debezium-sink-connector就报错：Invalid Java object for schema type INT64: class java.util.Long for field "null"。基本断定这是kafka-connector的bug，于是寻找其他方案，由于flink-connector使用的人较多，社区较活跃，尝试将kafka-connector换成：flink-connector，就是下面的方案二。

方案二为：mysql-cdc---->debezium-source-connector---->kafka----->flink-connector---->hana

经过验证，方案二执行过程中没有再出现方案一中的报错问题。

dbz用connector入hana报错Invalid Java object for schema type INT64: class java.util.Long for field “null“相关推荐

依赖包报错Invalid options object. Less Loader has been initialized using an options object that does not
1.问题:yarn安装依赖包,启动项目报错 error in ./node_modules/ant-design-vue/dist/antd.less Module build failed: Val ...
server 2008 mysql 报错 0xc000007b_docker插件部署项目,volumes报错invalid volume specification...
关于idea使用docker插件部署项目,volumes报错invalid volume specification 观察volumes那行,没写错的.但是........ 使用docker-comp ...
MATLAB报错Invalid ADAPTORNAME specified. Type 'imaqhwinfo' for a list of available ADAPTORNAMEs. Image
MATLAB报错Invalid ADAPTORNAME specified. Type 'imaqhwinfo' for a list of available ADAPTORNAMEs. Image ...
C# Excel导出超出65536行报错 Invalid row number (65536) outside allowable range (0..65535)
C# Excel导出超出65536行报错 Invalid row number (65536) outside allowable range (0-65535) 一:报错 Invalid row n ...
CRMEB知识付费系统安装搭建【常见问题-19.支付宝支付报错invalid [default store dir]: /tmp/】
支付宝支付报错 invalid [default store dir]: /tmp/ 1.如果使用支付宝sdk,首先lotusphp_runtime 文件也要一起使用支付宝现在的php sdk中有 ...
小程序报错 Invalid regular expression: invalid group specifier name
export const getFileType = (fileName) => {if (!fileName) return '';//↓此处报错 Invalid regular expres ...
兼容性问题：安卓正常，ios报错invalid group specifier name
翻了很多网上的解决办法,最终发现竟然是因为正则表达式出了问题,安卓和苹果支持的正则表达式格式可能不太一样,但是之前苹果机型一直没出问题,最近才出现问题常用零宽断言:?<=.?<!.?!. ...
mybatis报错 Invalid bound statement (not found)
mybatis报错 Invalid bound statement (not found) 第一步:查看接口mapper和对应的xml文件的id是否一致第二步:是由于maven默认加载机制造成 ma ...
微信二次分享签名错误php,微信二次分享报错invalid signature问题及解决方法
基于微信公众号开发的h5页面(使用jssdk接口),由用户A分享给用户B,用户B再次分享这个页面时,不能成功分享.问题出在用户B收到的分享链接与用户A打开的链接不同 A用户的链接为 B用户收到的连接 ...

dbz用connector入hana报错Invalid Java object for schema type INT64: class java.util.Long for field “null“

方案一为：mysql-cdc---->debezium-source-connector---->kafka----->debezium-sink-connector---->hana

方案二为：mysql-cdc---->debezium-source-connector---->kafka----->flink-connector---->hana

dbz用connector入hana报错Invalid Java object for schema type INT64: class java.util.Long for field “null“相关推荐

最新文章

热门文章