diff --git a/flinkx-connectors/flinkx-connector-mysql/src/main/java/com/dtstack/flinkx/connector/mysql/converter/MysqlRawTypeConverter.java b/flinkx-connectors/flinkx-connector-mysql/src/main/java/com/dtstack/flinkx/connector/mysql/converter/MysqlRawTypeConverter.java
index 805f5a559f..9788490baf 100644
--- a/flinkx-connectors/flinkx-connector-mysql/src/main/java/com/dtstack/flinkx/connector/mysql/converter/MysqlRawTypeConverter.java
+++ b/flinkx-connectors/flinkx-connector-mysql/src/main/java/com/dtstack/flinkx/connector/mysql/converter/MysqlRawTypeConverter.java
@@ -43,6 +43,7 @@ public static DataType apply(String type) {
             case "FLOAT UNSIGNED":
                 return DataTypes.FLOAT();
             case "DECIMAL":
+            case "DECIMAL128":
             case "DECIMAL UNSIGNED":
             case "NUMERIC":
                 return DataTypes.DECIMAL(38, 18);