Flink CDC看看有问题?就是不打印数据出来,执行图也不对
单表能同步
供的命令似乎存在一些问题,导致数据不打印和执行图错误。
首先,我注意到在命令中存在一些拼写错误和格式问题。下面是对命令进行修正的建议:
plaintext
Copy
EXECUTE CDC SOURCE Cac_postgresq1 WITH
connector = 'postgres-cdc',
hostname = 'pgm-wz9618mm74e89z3oqo.pg.rds.aliyuncs.com',
port = 5432,
username = 'your_username',
password = 'your_password',
source.server-time-zone = 'Asia/Shanghai',
checkpoint = '3008',
scan.startup.mode = 'initial',
parallelism = '1',
database-name = 'account',
schema-name = 'public',
table-name = 'account.menu_pool,account.role,account.role_menu',
sink.connector = ...
请注意,这只是对命令进行了格式上的修正。您需要根据实际情况填写正确的用户名和密码,并根据需要配置其他参数。
此外,您还需要提供有关您使用的 sink.connector 的详细信息,以便了解到数据的写入目标和相关配置。
请确保您的 Flink 环境正确配置并运行,还要确保 PostgreSQL 数据库和表的连接和权限设置正确。此外,检查 Flink 日志以获取任何错误或警告消息,以帮助排查问题。
确实
ds代码自己处理http://www.dlink.top/docs/next/data_integration_guide/cdcsource_statements#source-%E5%90%88%E5%B9%B6,https://github.com/DataLinkDC/dinky/pull/1933/commits/f272ef669e2d5f7a6178ed20b6fb06d89adb1138 pg整库同步都已经合并了, 0.73版本上就有,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。