diff --git a/fe/fe-core/src/main/java/org/apache/doris/external/jdbc/JdbcClient.java b/fe/fe-core/src/main/java/org/apache/doris/external/jdbc/JdbcClient.java index 8c02d48367..67d167500f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/external/jdbc/JdbcClient.java +++ b/fe/fe-core/src/main/java/org/apache/doris/external/jdbc/JdbcClient.java @@ -876,6 +876,8 @@ public class JdbcClient { fieldSchema.setDataTypeName(trinoArrType); Type type = trinoTypeToDoris(fieldSchema); return ArrayType.create(type, true); + } else if (trinoType.startsWith("varchar")) { + return ScalarType.createStringType(); } switch (trinoType) { case "integer": @@ -892,8 +894,6 @@ public class JdbcClient { return Type.FLOAT; case "boolean": return Type.BOOLEAN; - case "varchar": - return ScalarType.createStringType(); case "date": return ScalarType.createDateV2Type(); default: