(doris-flink-connector) branch master updated: [improve](cdc) add mysql set type for type mapping (#297)

[diwu]

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

diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git


The following commit(s) were added to refs/heads/master by this push:
     new 6e7d67f  [improve](cdc) add mysql set type for type mapping (#297)
6e7d67f is described below

commit 6e7d67f08168d6cc9ca07434c9a2d37587d8653d
Author: wudi <676366...@qq.com>
AuthorDate: Wed Jan 17 14:46:28 2024 +0800

    [improve](cdc) add mysql set type for type mapping (#297)
---
 .../src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
index 180414b..704b8b3 100644
--- 
a/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
+++ 
b/flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java
@@ -82,6 +82,7 @@ public class MysqlType {
     private static final String LONGBLOB = "LONGBLOB";
     private static final String JSON = "JSON";
     private static final String ENUM = "ENUM";
+    private static final String SET = "SET";
 
     public static String toDorisType(String type, Integer length, Integer 
scale) {
         switch (type.toUpperCase()) {
@@ -164,6 +165,7 @@ public class MysqlType {
             case LONGBLOB:
             case BINARY:
             case VARBINARY:
+            case SET:
                 return DorisType.STRING;
             case JSON:
                 return DorisType.JSONB;


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org