[jira] [Created] (FLINK-39397) postgres pk table encounted an error when delete a record

[Tao Wang (Jira)]

Tao Wang created FLINK-39397:
--------------------------------

             Summary: postgres pk table encounted an error when delete a record
                 Key: FLINK-39397
                 URL: https://issues.apache.org/jira/browse/FLINK-39397
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
    Affects Versions: cdc-3.6.0
            Reporter: Tao Wang
         Attachments: image-2026-04-03-16-08-11-260.png

source: postgress

schema:
{code:java}
// code placeholder
CREATE TABLE public."Upper_case_Test" ( 
id int4 GENERATED BY DEFAULT AS IDENTITY NOT NULL,      
"name" varchar NULL,    
dt varchar NULL,        
col_add_1 varchar NULL, 
col_add_2 varchar NULL, 
CONSTRAINT newtable_pk PRIMARY KEY (id));

{code}
 

 

task.yaml
{code:java}
// code placeholder

source:
  type: "postgres"
  hostname: "xxxxx"
  port: xxxx
  username: "xxxxx"
  password: "xxxxxx"
  tables: "postgres.public.Upper_case_Test"
  slot.name: "aaa"
  decoding.plugin.name: pgoutput
  schema-change.enabled: true
  scan.startup.mode: latest-offset
....
....

pipeline:
  name: pg_2_mysql
  parallelism: 1
  schema.change.behavior: EVOLVE



{code}
 

 

!image-2026-04-03-16-08-11-260.png|width=992,height=495!



--
This message was sent by Atlassian Jira
(v8.20.10#820010)