diff --git a/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/converter/ClickhouseRawTypeConverter.java b/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/converter/ClickhouseRawTypeConverter.java index bd4861b3b9..0a9a93c91d 100644 --- a/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/converter/ClickhouseRawTypeConverter.java +++ b/chunjun-connectors/chunjun-connector-clickhouse/src/main/java/com/dtstack/chunjun/connector/clickhouse/converter/ClickhouseRawTypeConverter.java @@ -96,6 +96,13 @@ public static DataType apply(TypeConfig type) { case "FIXEDSTRING": case "NESTED": return DataTypes.STRING(); + case "MAP(STRING,UINT8)": + case "MAP(STRING,INT8)": + case "MAP(STRING,UINT16)": + case "MAP(STRING,INT16)": + case "MAP(STRING,UINT32)": + case "MAP(STRING,INT32)": + return DataTypes.MAP(DataTypes.STRING(), DataTypes.INT()); case "DATE": return DataTypes.DATE(); case "TIME":