diff --git a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java index 79026e88f75..38412c347c0 100644 --- a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java +++ b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java @@ -22,6 +22,7 @@ public enum FieldType { INT, + INTEGER, TINYINT, SMALLINT, BIGINT, @@ -35,6 +36,7 @@ public enum FieldType { FIXED, BYTE, BINARY, + CHAR, VARCHAR, VARBINARY, BOOLEAN, @@ -44,6 +46,8 @@ public enum FieldType { INT16, INT32, INT64, + FLOAT4, + FLOAT8, FLOAT32, FLOAT64, DATETIME, @@ -54,7 +58,9 @@ public enum FieldType { MAP, STRUCT, FUNCTION, - KEYWORD; + KEYWORD, + LARGEINT, + JSON; public static FieldType forName(String name) { Preconditions.expectNotBlank(name, ErrorCodeEnum.INVALID_PARAMETER, "FieldType should not be null"); diff --git a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java index f04fabb41aa..6e6a0483d26 100644 --- a/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java +++ b/inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java @@ -297,6 +297,7 @@ public static FormatInfo convertFieldFormat(String type, String format) { formatInfo = new TimeFormatInfo(); } break; + case TIMESTAMPTZ: case TIMESTAMP: case DATETIME: if (StringUtils.isNotBlank(format)) {