From 2fe9ba7c2a89569c00bd8fa83f9e52d084ed74dd Mon Sep 17 00:00:00 2001 From: "yongkang.zhong" Date: Sat, 6 May 2023 17:16:28 +0800 Subject: [PATCH] [fix](jdbc catalog) fix trino jdbc catalog varchar type err (#19298) --- .../main/java/org/apache/doris/external/jdbc/JdbcClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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: