Flink CDC Caused by: mysql新加一个字段double，一直报这个？
Flink CDC Caused by: io.debezium.DebeziumException: Error processing binlog event at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:369) ~[debezium-connector-mysql-1.5.4.Final.jar:1.5.4.Final] at com.ververica.cdc.connectors.mysql.debezium.task.MySqlBinlogSplitReadTask.handleEveCaused by: java.lang.NumberFormatException: For input string: "0.00" at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) ~[?:1.8.0_151] at java.lang.Integer.parseInt(Integer.java:580) ~[?:1.8.0_151] at java.lang.Integer.valueOf(Integer.java:766) ~[?:1.8.0_151] at io.debezium.jdbc.JdbcValueConverters.lambda$convertInteger$41(JdbcValueConverters.java:892) ~[debezium-core-1.5.4.Final.jar:1.5.4.Final] at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1288) ~[debezium-core-1.5.4.Final.jar:1.5.4.Final] at io.debezium.jdbc.JdbcValueConverters.convertInteger(JdbcValueConverters.java:880) ~[debezium-core-1.5.4.Final.jar:1.5.4.Final] at io.debezium.jdbc.JdbcValueConverters.lambda$converter$5(JdbcValueConverters.java:295) ~[debezium-core-1.5.4.Final.jar:1.5.4.Final] at io.debezium.connector.mysql.MySqlDefaultValueConverter.setColumnDefaultValue( mysql新加一个字段double，一直报这个
写回答
-
MySqlBinlogSplitReadTask.handleEveCaused by: java.lang.NumberFormatException: For input string: "0.00" 数据类型匹配不对，此回答整理自钉群“Flink CDC 社区”
2023-06-18 12:39:08赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
