基于https://github.com/apache/bahir-flink.git当前的版本应该是flink1.12.2,kudu是1.13.0。
按照我自己的环境将flink升级到1.14.0也就是目前最新的版本,kudu降到1.10.0。
由于flink api的改动,所以修改了一丢丢源码,同时最后编译打包时跳过了deprecation警告,得到目前的包。
【环境:cdh6.3.2(kudu1.10.0)+flink1.14.0+scala2.11.12】简单测了一下可以使用,如遇问题欢迎骚扰~
1