Flink遇到的問題及解決方案

1. flink部署到集群上，standalone模式，需要指定TaskManager主機的地址：修改flink-conf.yaml配置並添加配置 taskmanager.host: localhost
否則提交job時，會報錯：TaskExecutor akka.tcp://xxx has no more allocated slots for job 

參考：單機Flink TaskExecutor no more allocated slots 問題解決 - 簡書 (jianshu.com)

2. 當job依賴於其它的jar包，比如kafka連接器、jdbc連接器，需要用maven將依賴的jar包也打入包中

3. 如果不好打入jar包中，並且使用頻率較高，可以將jar包放置在flink/lib目錄下，然后重啟集群

 

4. 寫入greenplum數據會翻倍，不知道為什么 

因為起了兩個flink服務。。關掉一個就好了