Flink CDC中从mysql同步到mysql中 提示这个错误?

Flink CDC中从mysql同步到mysql中 提示这个错误?mysql-cdc' can only be used as a source. It cannot be used as a sink
版本是flink1.17,flink-cdc:2.21,
sql语句:
CREATE TABLE demo1 (
id INT,
name STRING,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' = 'mysql-cdc',
'username' = 'root',
'password' = '123456',

'table-name' = 'demo1',
'database-name' = 'flink',
'hostname' = '192.168.66.237',
'port' = '3306'
);

CREATE TABLE demo2 (
id INT,
name STRING,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' = 'mysql-cdc',
'username' = 'root',
'password' = '123456',

'table-name' = 'demo2',
'database-name' = 'flink',
'hostname' = '192.168.66.237',
'port' = '3306'
);

insert into demo2 select * from demo1;

展开
收起
真的很搞笑 2023-09-20 13:10:54 252 分享 版权
1 条回答
写回答
取消 提交回答
  • cdc 不能做sink, sink你用jdbc的connector 吧,此回答整理自钉群“Flink CDC 社区”

    2023-09-20 15:43:23
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理