Flink-环境搭建

Flink-环境搭建

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

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

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

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

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

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

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

重启客户端（JobManager）

./bin/jobmanager.sh start

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。