From a400a045304f34dfd9d0727d6286402d856785b7 Mon Sep 17 00:00:00 2001
From: kino <416595168@qq.com>
Date: Thu, 12 May 2022 16:44:26 +0800
Subject: [PATCH] [hotfix-793]Fix JDBC Source TypeConverter Error

---
 .../flinkx/connector/mysql/converter/MysqlRawTypeConverter.java  | 1 +
 1 file changed, 1 insertion(+)

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);