第一次向线上提交flink任务遇到的一堆坑

flink版本 flink1.7.0_scala2.12.tar.gz   本项目包括内容 1.从kafka消费,结果写入kafka 2.中间有部分数据存入redis   问题描述 开始我没有注意scala版本问题,在pom中flink用的1.7.0,scala用的2.11.0,idea设置的scala环境也是2.11.0 在本地编译运行完全正常,然后使用build artifacts打出一个包含
相关文章
相关标签/搜索