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 180414ba2..704b8b300 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 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;