本文共 456 字,大约阅读时间需要 1 分钟。
创建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
转载地址:http://gdhws.baihongyu.com/