Flink cdc-connector databaselist 这个是不是不支持正则啊?
但是我配置 好像不生效呢。。比如 我现在有一些库 aa_cc库 aa_bb库 我是不是应该设置 databaselist = aa.* 这样呢?
Flink-CDC 数据库连接器通常支持正则表达式来匹配数据库名称,但具体的实现可能因版本和配置而异。您可以尝试使用正则表达式来匹配数据库名称,但需要确保您的配置正确。
在配置 databaselist
时,您需要使用正确的正则表达式语法,并确保正则表达式与您的数据库名称匹配。根据您提供的信息,您可以尝试以下配置:
databaselist = ^aa.*$
上述配置使用了正则表达式 ^aa.*$
,它匹配以 "aa" 开头且后面跟着任意字符的数据库名称。您可以将这个配置添加到您的 Flink-CDC 连接器配置中,然后重新启动 Flink 任务进行测试。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。