创建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中,执行解压命令
解压完毕之后执行下面命令启动flink,flink默认绑定端口8081
// 这个命令同时会启动其他机器上的TaskManager,似乎这是与jobmanager.sh的区别./bin/start-cluster.sh
然后从浏览器进入:服务器地址:8081,会显示出flink管理页面,如果正确访问该页面,说明flink启动成功
重启客户端(JobManager)
./bin/jobmanager.sh start