先上图 运行界面
运行了三个任务
第一个是word count
第二三个是 数据 producer and consumer ----> 更多代码 可以参考上一篇blog 里面有很详细的介绍
在数据从idea 导出jar 包 已经 运行的过程中遇到两个问题
1，导出时候 因为是单机环境 需要把 kafka 等相关的依赖 一起导出
参考这个blog ，主要是要勾选 include in project build 该项 ，thanks
https://www.cnblogs.com/ALittleMoreLove/archive/2018/08/09/9449992.html
2， 另一个错误是没有足够的 slots ，这个从overview 中找到 ，需要修改 flink-conf.yaml 文件中的 taskmanager.numberoftaskslots = 8 ,默认是 1 （我们起的任务大于1 了 所以 造成失败）
具体可以参考这个blog thanks
https://blog.csdn.net/boling_cavalry/article/details/85213905
尼泊尔 珠峰大本营 ，以及昆布冰川