第一次向線上提交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 在本地編譯運行徹

>>阅读原文<<