博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Flink-环境搭建
阅读量:4303 次
发布时间:2019-05-27

本文共 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/

你可能感兴趣的文章
maven打包本地依赖包
查看>>
spring boot jpa 实现拦截器
查看>>
jenkins + maven+ gitlab 自动化部署
查看>>
Pull Request流程
查看>>
Lambda 表达式
查看>>
函数式数据处理(一)--流
查看>>
java 流使用
查看>>
java 用流收集数据
查看>>
java并行流
查看>>
CompletableFuture 组合式异步编程
查看>>
mysql查询某一个字段是否包含中文字符
查看>>
Java中equals和==的区别
查看>>
JVM内存管理及GC机制
查看>>
Java:按值传递还是按引用传递详细解说
查看>>
Java中Synchronized的用法
查看>>
阻塞队列
查看>>
linux的基础知识
查看>>
接口技术原理
查看>>
五大串口的基本原理
查看>>
PCB设计技巧与注意事项
查看>>