add mysql type

JNSimba · Jan 17, 2024 · fca7904 · fca7904
1 parent 46de849
commit fca7904
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -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 static String toDorisType(String type, Integer length, Integer scale) {
             case LONGBLOB:
             case BINARY:
             case VARBINARY:
+            case SET:
                 return DorisType.STRING;
             case JSON:
                 return DorisType.JSONB;