Flink-环境搭建_flink环境搭建

一： 创建Flink程序
随便找个文件夹执行下面的maven命令

mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-java -DarchetypeVersion=1.7.0
1

由于现在使用的IDE是intellij，所以也记录一下intellij导入项目时遇见的问题，将刚刚生成的maven项目导入到intellij需要注意2点：
1. 先将自己的settings.xml文件放到C:\Users\admin.m2\settings.xml，下，因为只要导入项目，IDEA默认就去这个地方找，如果没找到，就会出现各种奇怪问题，即使我们后续在intellij中修改了正确位置，但是此时问题已经出现，还得各种clean什么的，相当麻烦
2. 只有一个POM文件，有时候导入项目的时候，intellij中只有一个pom文件，此时需要File->Project Structure->Project Settings->Modules->此时左侧（+）加号下面区域什么都没有，点击加号->Import Modules->选择刚刚生成的项目->OK
二：windows系统安装NC程序，这样调试流程序非常方便
去https://eternallybored.org/misc/netcat/网站下载netcat，下载之后解压出来一个文件夹，我当时的版本是netcat-1.11，然后将这个netcat-1.11文件夹配置到环境变量，这样就可以在cmd下使用如下命令连接9000端口了

C:\Users\admin>nc -lp 9000
1

NOTE：lp命令执行完之后，可以在下面输入内容，例如下面的示例就是输入了几个字母，此时如果flink程序也连接了9000端口，则flink会接到bb，cc，dd

C:\Users\admin>nc -lp 9000
bb
cc
dd
1
2
3
4

三：服务器上安装Flink容器
先去官网下载好flink，然后拖拽到XShell中，执行解压命令

tar -zxvf flink-1.11.1-bin-scala_2.11.tgz 
1

解压完毕之后执行下面命令启动flink，flink默认绑定端口8081

// 这个命令同时会启动其他机器上的TaskManager，似乎这是与jobmanager.sh的区别
./bin/start-cluster.sh
1
2

然后从浏览器进入：服务器地址:8081，会显示出flink管理页面，如果正确访问该页面，说明flink启动成功

重启客户端（JobManager）

./bin/jobmanager.sh start
1

下一篇：StreaminDemo