Skip to content

Commit c088e46

Browse files
author
och5351
committed
🔥 : hotfix : postgresql uuid type support
1 parent 85d5c6b commit c088e46

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

‎flink-connector-jdbc-postgres/src/main/java/org/apache/flink/connector/jdbc/postgres/database/catalog/PostgresTypeMapper.java‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,6 @@ public class PostgresTypeMapper implements JdbcCatalogTypeMapper {
8585
private static final String PG_CHARACTER_VARYING = "varchar";
8686
private static final String PG_CHARACTER_VARYING_ARRAY = "_varchar";
8787
private static final String PG_UUID = "uuid";
88-
private static final String PG_UUID_ARRAY = "_uuid";
8988

9089
@Override
9190
public DataType mapping(ObjectPath tablePath, ResultSetMetaData metadata, int colIndex)
@@ -180,8 +179,6 @@ protected DataType getMapping(String pgType, int precision, int scale) {
180179
return DataTypes.ARRAY(DataTypes.DATE());
181180
case PG_UUID:
182181
return DataTypes.VARCHAR(36);
183-
case PG_UUID_ARRAY:
184-
return DataTypes.ARRAY(DataTypes.VARCHAR(36));
185182
default:
186183
return null;
187184
}

0 commit comments

Comments
 (0)