From d780de556752ef4b1885a54ea9524d8f605bc606 Mon Sep 17 00:00:00 2001 From: Kieran Colford Date: Thu, 28 Aug 2025 20:06:23 -0400 Subject: [PATCH] Add Postgresql UUID catalog support --- .../jdbc/postgres/database/catalog/PostgresTypeMapper.java | 3 +++ 1 file changed, 3 insertions(+) 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: