-
Notifications
You must be signed in to change notification settings - Fork 210
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
mysql到mysql端实时同步问题,修改源表字段内容,目标表不会更新源表修改的内容,而是重新生成一条新的记录 #267
Comments
baisui1981
added a commit
to qlangtech/chunjun
that referenced
this issue
Oct 3, 2023
原因分析sink 端执行链路TISMysqlOutputFormat -> MysqlOutputFormat -> JdbcOutputFormat#writeMultipleRecordsInternal() -> PreparedStmtProxy.convertToExternal() -> JdbcColumnConverter.toExternal() -> PreparedStmtProxy.setLong(pos,val) 故障点IFieldNamesAttachedStatement.java 中: default void setLong(int pos, Long val) throws SQLException {
getFieldNamedPstmt().setDouble(pos, val);
} 设置long时错误调用代理类的setDouble方法,应改为: default void setLong(int pos, Long val) throws SQLException {
getFieldNamedPstmt().setLong(pos, val);
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
@喜楽
source 为mysql8 ,destination为 mysql5
复现:
建表语句:
初始化数据:
更新数据:
The text was updated successfully, but these errors were encountered: