-
JDK：1.8.0_211
-
Maven：3.6.0
-
IDEA：2018.3.5 (Ultimate Edition)
-
Flink版本：1.9.2
关于正版IDEA
如何免费使用正版IDEA，可以参考《免费申请和使用IntelliJ IDEA商业版License指南》
开发
-
首先确保您电脑上maven已装好；
-
创建一个flink任务的maven工程，找个干净目录执行以下命令：
mvn \
archetype:generate \
-DarchetypeGroupId=org.apache.flink \
-DarchetypeArtifactId=flink-quickstart-java \
-DarchetypeVersion=1.9.2
- 按提示输入groupId、artifactId、version、package等内容：
- 现在maven工程已生成，用IDEA导入这个工程，如下图：
- 以maven的类型导入：
- 导入成功后的样子：
- 修改StreamingJob.java，加入功能是监听本地18081端口，得到的字符串做word count操作，完整代码在此下载：https://raw.githubusercontent.com/zq2599/blog_demos/master/files/StreamingJob.java
- 现在的代码已经能运行，但flink网页却还不能访问，会显示以下错误信息，需要继续做些设置：
- 下载flink-1.9.2安装包，这里面有flink网页服务用到的一个jar，地址是：https://www-eu.apache.org/dist/flink/flink-1.9.2/flink-1.9.2-bin-scala_2.11
《一线大厂Java面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》
【docs.qq.com/doc/DSmxTbFJ1cmN1R2dB】 完整内容开源分享
.tgz
-
flink-1.9.2-bin-scala_2.11.tgz下载后解压，在lib目录下有个flink-dist_2.11-1.9.2.jar文件，记住此文件的位置，稍后会用到；
-
回到IDEA，在项目上点击右键，点击菜单Open Module Settings：
- 在弹出的窗口做如下操作，目的是给项目中增加jar：
- 弹出选择文件的窗口，请选择刚才准备好的文件flink-dist_2.11-1.9.2.jar：
