This is an automated email from the ASF dual-hosted git repository.
fanjia 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 86b1b7e31 [Feature][Connector-V2][mysql cdc] Conversion of tinyint(1)
to bool is supported (#5105)
86b1b7e31 is described below
commit 86b1b7e31a351dafc31404f1b3262f0bc0ee70be
Author: Carl-Zhou-CN <[email protected]>
AuthorDate: Thu Jul 20 12:59:37 2023 +0800
[Feature][Connector-V2][mysql cdc] Conversion of tinyint(1) to bool is
supported (#5105)
Co-authored-by: zhouyao <[email protected]>
---
.../seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
index 01760bfc9..267476b3f 100644
---
a/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
+++
b/seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java
@@ -87,6 +87,7 @@ public class MySqlTypeUtils {
case MYSQL_BIT:
return BasicType.BOOLEAN_TYPE;
case MYSQL_TINYINT:
+ return column.length() == 1 ? BasicType.BOOLEAN_TYPE :
BasicType.INT_TYPE;
case MYSQL_TINYINT_UNSIGNED:
case MYSQL_SMALLINT:
case MYSQL_SMALLINT_UNSIGNED:
