住房城乡建设部网站通报,可以做内容的网站,网站怎么做海外推广,wordpress 微博小工具0 flink版本 踩雷
java代码操作 flink Table/SQL API 和 DataStream API 编写程序后#xff0c;打成jar包丢到flink集群运行#xff0c;报错首选需要考虑flink集群版本和 jar包中maven依赖的版本是否一致。 目前网上flink、flinkcdc相关博文绝大部分是基于flink1.13、1.14编…0 flink版本 踩雷
java代码操作 flink Table/SQL API 和 DataStream API 编写程序后打成jar包丢到flink集群运行报错首选需要考虑flink集群版本和 jar包中maven依赖的版本是否一致。 目前网上flink、flinkcdc相关博文绝大部分是基于flink1.13、1.14编写的而我的flink集群是1.15 而flink1.15由于只支持scala-2.12所以maven依赖包名发生了改变
!-- 1.15之前的版本 artifactId 会有一个用来区分不同scala版本的“_2.12”、“_2.11”后缀 --
dependencygroupIdorg.apache.flink/groupIdartifactIdflink-streaming-java_2.12/artifactIdversion1.14.5/version
/dependency!-- 1.15版本的 artifactId 没有用来区分不同scala版本的“_2.12”后缀原因也是1.15只支持scala-2.12 --
dependencygroupIdorg.apache.flink/groupIdartifactIdflink-streaming-java/artifactIdversion1.15.2/version
/dependency需要特别说明的是在flink-connector-mysql-cdc模块的pom文件中有一个flink-table-planner的依赖这个依赖的 artifactId 不用更改这个依赖在1.15版本中artifactId 也是带 scala版本后缀的
dependencygroupIdorg.apache.flink/groupIdartifactIdflink-table-planner_2.12/artifactIdversion1.15.2/version/dependency我是文章1和文章2才知道踩的这个坑
如果你的flink集群是1.13 请参考这篇教程一文弄懂Flink CDC
如果你想开发完后将任务丢到flink集群上运行请根据你的flink集群版本选择正确的maven依赖
