写回答
-
看下ddl，先把最后一行注释掉，先不用增量快照框架读取，测试下普通的能不能运
你没装 decoderbufs 插件，试下那个配置项用 wal2json 或者 pgoutput
pgoutput 这个默认就有，可以用这个试试，此回答整理自钉群“Flink CDC 社区”2023-11-08 07:39:44赞同 展开评论 打赏 -
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。这个错误可能由多种原因引起，请查看一下提示信息中的详细内容，并尝试以下几种方法来解决此问题：
- 检查 flink-sql-client 配置文件中的配置项是否正确，并确保所有必需选项都已设置。
- 检查 Flink 集群上安装的所有 JAR 文件，并确保它们处于正确的版本级别。
- 检查与 SQL 作业相关的库文件是否已安装并且可用。
- 尝试运行其他简单的 SQL 作业，以验证集群的整体状态是否正常。
2023-11-06 14:42:40赞同 展开评论 打赏 -
执行Flink job，报错“Could not execute SQL statement. Reason:org.apache.flink.table.api.ValidationException: One or more required options are missing”，该如何解决？
报错原因
在StarRocks-migrate-tools（简称SMT）配置文件config_prod.conf中设置了多组规则[table-rule.1]、[table-rule.2]等，但是缺失必要的配置信息。解决方案
检查是否给每组规则[table-rule.1]、[table-rule.2]等配置了database，table和Flink Connector信息。https://help.aliyun.com/zh/emr/emr-on-ecs/user-guide/faq-9?spm=a2c4g.750001.0.i1#section-zew-t9e-zbk
2023-11-06 14:01:53赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关课程
更多
相关文章
相关电子书
更多
