diff --git a/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java b/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java index 5fc19ea36..fe2481774 100644 --- a/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java +++ b/flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java @@ -84,6 +84,7 @@ public class PostgresTypeMapper implements JdbcCatalogTypeMapper { private static final String PG_CHARACTER_ARRAY = "_character"; private static final String PG_CHARACTER_VARYING = "varchar"; private static final String PG_CHARACTER_VARYING_ARRAY = "_varchar"; + private static final String PG_UUID = "uuid"; @Override public DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int colIndex) @@ -154,6 +155,8 @@ protected DataType getMapping(String pgType, int precision, int scale) { return DataTypes.ARRAY(DataTypes.CHAR(precision)); case PG_CHARACTER_VARYING: return DataTypes.VARCHAR(precision); + case PG_UUID: + return DataTypes.VARCHAR(36); case PG_CHARACTER_VARYING_ARRAY: return DataTypes.ARRAY(DataTypes.VARCHAR(precision)); case PG_TEXT: