0
点赞
收藏
分享

微信扫一扫

Flink-环境搭建

zhyuzh3d 2022-07-12 阅读 40


创建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


举报

相关推荐

0 条评论