update

Author: Hisoka-X

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/utils/PostgresTypeUtils.java

@@ -159,6 +159,7 @@ private static DataType convertFromColumn(
             case PgOid.DATERANGE_OID:
                 return DataTypes.STRING();
             case PgOid.TEXT_ARRAY:
+            case PgOid.UUID_ARRAY:
                 return DataTypes.ARRAY(DataTypes.STRING());
             case PgOid.TIMESTAMP:
                 return handleTimestampWithTemporalMode(temporalPrecisionMode, scale);

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/java/org/apache/flink/cdc/connectors/postgres/source/PostgresFullTypesITCase.java

@@ -873,6 +873,12 @@ public void testArrayTypes() throws Exception {
 
         ArrayData actualIntArray = (ArrayData) actualSnapshotObjects[3];
         Assertions.assertThat(actualIntArray.getInt(0)).isEqualTo(42);
+
+        ArrayData actualUuidArray = (ArrayData) actualSnapshotObjects[4];
+        Assertions.assertThat(actualUuidArray.getString(0))
+                .isEqualTo(BinaryStringData.fromString("a0eebc99-9c0b-4ef8-bb6d-6bb9bd380a11"));
+        Assertions.assertThat(actualUuidArray.getString(1))
+                .isEqualTo(BinaryStringData.fromString("b0eebc99-9c0b-4ef8-bb6d-6bb9bd380a22"));
     }
 
     @Test
@@ -1117,7 +1123,8 @@ private Instant toInstant(String ts) {
                     DataTypes.INT(),
                     DataTypes.ARRAY(DataTypes.STRING()),
                     DataTypes.ARRAY(DataTypes.INT()),
-                    DataTypes.ARRAY(DataTypes.INT()));
+                    DataTypes.ARRAY(DataTypes.INT()),
+                    DataTypes.ARRAY(DataTypes.STRING()));
 
     private static final RowType ARRAY_TYPES_WITH_NULL =
             RowType.of(

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/test/resources/ddl/column_type_test.sql

@@ -159,18 +159,20 @@ CREATE TABLE array_types (
                             id        SERIAL PRIMARY KEY,
                             text_a1  TEXT[],
                             int_a1    INTEGER[],
-                            int_s1 INTEGER[]
+                            int_s1 INTEGER[],
+                            uuid_a1 UUID[]
 );
 
 ALTER TABLE inventory.array_types
     REPLICA IDENTITY FULL;
 
-INSERT INTO array_types (id,text_a1, int_a1, int_s1)
+INSERT INTO array_types (id,text_a1, int_a1, int_s1, uuid_a1)
 VALUES
     (1,
      ARRAY['electronics', 'gadget', 'sale'],
      '{85, 90, 78}',
-     '{42}'
+     '{42}',
+     ARRAY['a0eebc99-9c0b-4ef8-bb6d-6bb9bd380a11', 'b0eebc99-9c0b-4ef8-bb6d-6bb9bd380a22']::UUID[]
     );
 
 CREATE TABLE array_types_with_null (