From 4bd917cb7bd1fa39ff644871bd10f9154059a02d Mon Sep 17 00:00:00 2001 From: zy-kkk Date: Mon, 3 Mar 2025 14:51:27 +0800 Subject: [PATCH] [fix](jdbc catalog) Use factory methods to return mapped types instead 2 --- .../apache/doris/datasource/jdbc/client/JdbcMySQLClient.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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":