使用官方方法 Maven package 出來的 SocketWindowWordCount 在服務器上 flink run 報錯，flatMap處報的錯
$ mvn archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-scala \
-DarchetypeVersion=1.7.2
然后用 IDEA import maven 專案
復制 flink 官方例子原始碼（自己修改了點，不礙事）：
在本地 Run 沒有任何問題（配合了 nc -l 8080）：
然后開始打包，先在 pom.xml 里把入口類改為 SocketWindowWordCount，點 IDEA 右上角 Maven 里的 packge：
打包出來了個 jar 檔案，把它傳到服務器上 flink run 報錯（配合了 nc -l 8080）：
一旦在 8080 埠敲幾個字符 enter 下就會報上面的錯，很難受，在 Windows IDEA 上好好的
然后把 flatMap 那一行代碼注釋掉：
重新 packge，上傳，flink run，沒有問題：
哇，真滴難受，搞了很久無果
有哪位前輩來指點一手，感激不盡
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/41014.html
標籤：Spark
上一篇：第二章、網路應用
下一篇：ceph 物件存盤用戶使用量統計