You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by bmw <pa...@163.com> on 2022/12/02 02:09:37 UTC

FLINK postgresql CDC 报语法错误

HI flink postgresql CDC  flink1.12  ,postgresql:9.6.21 报错：
CREATE TABLE postgres_cdc_test (
  id INT,
  name STRING,
  PRIMARY KEY (id) NOT ENFORCED 
) WITH (
  'connector' = 'postgres-cdc',           
  'hostname' = '192.168.1.101',            
  'port' = '5432',                          
  'username' = 'postgres',            
  'password' = 'test',             
  'database-name' = 'test',    
  'schema-name' = 'public',      
  'table-name' = 'test',           
  'debezium.slot.name' = 'customslotname',  
  'decoding.plugin.name' = 'pgoutput'
);


错误信息：

Re:FLINK postgresql CDC 报语法错误

Posted by bmw <pa...@163.com>.
是查询的时候报错,建表是成功的。
select * from postgres_cdc_test 
错误：
[ERROR] Could not execute SQL statement. Reason:
org.postgresql.util.PSQLException: ERROR: syntax error


















在 2022-12-02 10:09:37，"bmw" <pa...@163.com> 写道：

HI flink postgresql CDC  flink1.12  ,postgresql:9.6.21 报错：
CREATE TABLE postgres_cdc_test (
  id INT,
  name STRING,
  PRIMARY KEY (id) NOT ENFORCED 
) WITH (
  'connector' = 'postgres-cdc',           
  'hostname' = '192.168.1.101',            
  'port' = '5432',                          
  'username' = 'postgres',            
  'password' = 'test',             
  'database-name' = 'test',    
  'schema-name' = 'public',      
  'table-name' = 'test',           
  'debezium.slot.name' = 'customslotname',  
  'decoding.plugin.name' = 'pgoutput'
);


错误信息：