mysql-cdc，读取binlog异常,, Error processing binlog event

[aokinba]

定位到原因，字段的默认值设置错了
但是flink重启，每次都从最新的checkpoint读取，怎么跳过这个错误呢？

`relax_heat_temperature` TINYINT UNSIGNED NOT NULL DEFAULT '0.00'

Caused by: java.lang.NumberFormatException: For input string: "0.00"

    at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) ~[?:1.8.0_302]


    at java.lang.Integer.parseInt(Integer.java:580) ~[?:1.8.0_302]


    at java.lang.Short.parseShort(Short.java:118) ~[?:1.8.0_302]


    at java.lang.Short.valueOf(Short.java:174) ~[?:1.8.0_302]


    at java.lang.Short.valueOf(Short.java:200) ~[?:1.8.0_302]


    at io.debezium.jdbc.JdbcValueConverters.lambda$convertSmallInt$40(JdbcValueConverters.java:865) ~[app.jar:?]


    at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1288) ~[app.jar:?]


    at io.debezium.jdbc.JdbcValueConverters.convertSmallInt(JdbcValueConverters.java:853) ~[app.jar:?]


    at io.debezium.connector.mysql.MySqlValueConverters.lambda$convertUnsignedTinyint$24(MySqlValueConverters.java:651) ~[app.jar:?]


    at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1288) ~[app.jar:?]


    at io.debezium.connector.mysql.MySqlValueConverters.convertUnsignedTinyint(MySqlValueConverters.java:642) ~[app.jar:?]


    at io.debezium.connector.mysql.MySqlValueConverters.lambda$converter$7(MySqlValueConverters.java:257) ~[app.jar:?]


    at io.debezium.connector.mysql.MySqlDefaultValueConverter.setColumnDefaultValue(MySqlDefaultValueConverter.java:405) ~[app.jar:?]


    at io.debezium.connector.mysql.antlr.listener.CreateTableParserListener.convertDefaultValueToSchemaType(CreateTableParserListener.java:147) ~[app.jar:?]


    at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_302]


    at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) ~[?:1.8.0_302]


    at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384) ~[?:1.8.0_302]


    at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) ~[?:1.8.0_302]


    at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) ~[?:1.8.0_302]


    at java.util.stream.ReduceOps$Re

[aokinba]

已解决问题，添加ddl语句过滤即可