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

flink版本html flink1.7.0_scala2.12.tar.gzjava   本项目包括内容web 1.从kafka消费,结果写入kafkaredis 2.中间有部分数据存入redisapache   问题描述json 开始我没有注意scala版本问题,在pom中flink用的1.7.0,scala用的2.11.0,idea设置的scala环境也是2.11.0api 在本地编译运行彻
相关文章
相关标签/搜索