1. flink部署到集群上，standalone模式，需要指定TaskManager主机的地址：修改flink-conf.yaml配置并添加配置 taskmanager.host: localhost
否则提交job时，会报错：TaskExecutor akka.tcp://xxx has no more allocated slots for job
2. 当需要其它的jar包时，比如kafka连接器、jdbc连接器，需要maven将依赖也打入包中
3. 不好打入jar包中，并且使用频率较高的jar包，可以放置在flink/lib目录下，然后重启集群
4. 写入greenplum数据会翻倍，不知道为什么 ---doing
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
