Hi all, I have came across a problem with a Postgres JDBC connector. I am not sure, but I don’t think this is expected behavior. I have the following context: • Pipeline source Postgres CDC • Pipeline sink Postgres JDBC If I make a change in the source table, and print the changelog stream:

-D[1,83819211,545900928]
+I[-83819211,83819211,545900928]

This is expected, it should remove the record having primary key 1, and insert the record having primary key -83819211. If I check the database after this change, I see the following:

-----------+----------------+--------------------
 -83819211 |       83819211 |          545900928
         1 |       83819211 |          545900928

It suggests that the delete statement has not been executed. Anyone that can help?

Are you using DataStream or Table API?

Table API

Have you configured the primary key in the DDL?

Yes I have, this is what I get when printing the result from the schema builder:

(
  `family_id` INT NOT NULL,
  `representative` INT NOT NULL,
  `invention_title_id` BIGINT,
  CONSTRAINT `PK_family_id` PRIMARY KEY (`family_id`) NOT ENFORCED
)
COMMENT ''
WITH (
  'password' = 'root',
  'connector' = 'jdbc',
  'driver' = 'org.postgresql.Driver',
  'table-name' = 'family',
  'url' = 'jdbc:<postgresql://localhost:5432/database>',
  'username' = 'root'
)