Flink CDC中这个怎么解决?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
根据您提供的代码片段,有一些错误和格式问题。以下是修正后的代码片段:
xml
Copy
org.apache.maven.plugins
maven-compiler-plugin
3.8.1
8
8
UTF-8
org.springframework.boot
spring-boot-maven-plugin
${spring-boot.version}
com.akudouzi.flink.cdc.FlinkCdcMysql2esApplication
true
repackage
repackage
修正后的代码片段中,主要进行了以下更改:
-> :修正了 标签的拼写错误。
8:将 的值设置为 Java 8,以指定编译生成的字节码版本。
true:指定 为 true,跳过 Spring Boot 的 Maven 插件执行。
不要和spring整合,这是个累赘,flink需要spring什么功能吗,不需要,要他就是累赘还没用。flink和es有自己的连接器。在sql-client客户端里面写flink-sql。此回答整理至钉群“Flink CDC 社区”。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。