当前位置 : 主页 > 编程语言 > java >

Flink-环境搭建

来源:互联网 收集:自由互联 发布时间:2022-07-13
创建Flink程序,随便找个文件夹执行下面的maven命令 mvn archetype : generate - DarchetypeGroupId = org . apache . flink - DarchetypeArtifactId = flink - quickstart - java - DarchetypeVersion = 1.7.0 服务器上安装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


上一篇:docker部署rabbitmq的正确方法
下一篇:没有了
网友评论