第一次向線上提交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打出一個包含

>>阅读原文<<