diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java index d69740a9269a8d..a02830f325518e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/jdbc/client/JdbcMySQLClient.java @@ -18,7 +18,6 @@ package org.apache.doris.datasource.jdbc.client; import org.apache.doris.catalog.ArrayType; -import org.apache.doris.catalog.PrimitiveType; import org.apache.doris.catalog.ScalarType; import org.apache.doris.catalog.Type; import org.apache.doris.common.util.Util; @@ -383,9 +382,7 @@ private Type dorisTypeToDoris(JdbcFieldSchema fieldSchema) { } case "CHAR": case "CHARACTER": - ScalarType charType = ScalarType.createType(PrimitiveType.CHAR); - charType.setLength(fieldSchema.requiredColumnSize()); - return charType; + return ScalarType.createCharType(fieldSchema.requiredColumnSize()); case "VARCHAR": return ScalarType.createVarcharType(fieldSchema.requiredColumnSize()); case "STRING":