[seatunnel] branch dev updated: [Bugfix][cdc] Fix mysql bit column to java byte (#4817)

[wanghailin]

This is an automated email from the ASF dual-hosted git repository.

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new aae3e913d0 [Bugfix][cdc] Fix mysql bit column to java byte (#4817)
aae3e913d0 is described below

commit aae3e913d06e5a53a58feacc68423bb0c318237d
Author: gejinxin <844156...@qq.com>
AuthorDate: Wed Aug 9 11:47:51 2023 +0800

    [Bugfix][cdc] Fix mysql bit column to java byte (#4817)
---
 .../cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java
 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java
index bffd3ee438..bec86250dd 100644
--- 
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java
+++ 
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java
@@ -210,6 +210,8 @@ public class SeaTunnelRowDebeziumDeserializationConverters 
implements Serializab
                     return dbzObj;
                 } else if (dbzObj instanceof BigDecimal) {
                     return ((BigDecimal) dbzObj).byteValue();
+                } else if (dbzObj instanceof Boolean) {
+                    return Boolean.TRUE.equals(dbzObj) ? Byte.valueOf("1") : 
Byte.valueOf("0");
                 } else {
                     return Byte.parseByte(dbzObj.toString());
                 }