Apache Flink 零基础入门(二):使用docker快速搭建Flink
使用docker拉取镜像
docker pull flink
镜像拉取好之后,检查一下:
iie4bu@swarm-manager:~/ddy/docker-flink$ docker image ls
REPOSITORY TAG IMAGE ID CREATED SIZE
flink latest 10a60ef23105 7 days ago 574MB
新建文件夹docker-flink,文件夹下新建文件docker-compose.yml,内容如下:
version: "2.1"
services:jobmanager:image: flinkexpose:- "6123"ports:- "8081:8081"command: jobmanagerenvironment:- JOB_MANAGER_RPC_ADDRESS=jobmanagertaskmanager:image: flinkexpose:- "6121"- "6122"depends_on:- jobmanagercommand: taskmanagerlinks:- "jobmanager:jobmanager"environment:- JOB_MANAGER_RPC_ADDRESS=jobmanager
启动docker-compose
docker-compose up -d
浏览器打开 http://127.0.0.1:8081 可以看到dashboard
这样环境就搭建好了.
进入容器中可以查看flink版本:flink --version
Apache Flink 零基础入门(二):使用docker快速搭建Flink相关推荐
- Apache Flink 零基础入门【转】
Apache Flink 零基础入门(一):基础概念解析 Apache Flink 零基础入门(二):DataStream API 编程 转载于:https://www.cnblogs.com/dav ...
- Apache Flink 零基础入门(一):基础概念解析
Apache Flink 的定义.架构及原理 Apache Flink 是一个分布式大数据处理引擎,可对有限数据流和无限数据流进行有状态或无状态的计算,能够部署在各种集群环境,对各种规模大小的数据进行 ...
- Apache Flink 零基础入门(二十)Flink部署与作业的提交
之前我们都是基于Idea在本地进行开发,这种方式很适合开发以及测试,但是开发完之后,如何提交到服务器中运行? Flink单机部署方式 本地开发和测试过程中非常有用,只要把代码放到服务器直接运行. 前置 ...
- Apache Flink 零基础入门(二十)Flink kafka connector
内置source和sink 内置source包括从文件读取,从文件夹读取,从socket中读取.从集合或者迭代器中读取.内置的sink包括写文件.控制台输出.socket 内置connectors A ...
- Apache Flink 零基础入门(二十一)Flink HistoryServer概述与配置
之前我们做了Flink的开发,开发完成之后就需要进行监控. Flink 有一个History Server可以在相关Flink 集群关闭之后,还可以查看一些信息.也就是一些作业运行完成之后,可以用Hi ...
- Apache Flink 零基础入门(十二)Flink sink
将DataSet中的数据Sink到哪里去.使用的是对应的OutPutFormat,也可以使用自定义的sink,有可能写到hbase中,hdfs中. writeAsText() / TextOutput ...
- Apache Flink 零基础入门(十五)Flink DataStream编程(如何自定义DataSource)
数据源可以通过StreamExecutionEnvironment.addSource(sourceFunction)方式来创建,Flink也提供了一些内置的数据源方便使用,例如readTextFil ...
- Apache Flink 零基础入门(七)Flink中keyBy三种方式指定key
keyBy 如何指定key 不管是stream还是batch处理,都有一个keyBy(stream)和groupBy(batch)操作.那么该如何指定key? Some transformations ...
- Apache Flink 零基础入门(十九)Flink windows和Time操作
Time类型 在Flink中常用的Time类型: 处理时间 摄取时间 事件时间 处理时间 是上图中,最后一步的处理时间,表示服务器中执行相关操作的处理时间.例如一些算子操作时间,在服务器上面的时间. ...
最新文章
- datagridview控件读写mysql数据库表格的方法_C#读写Access数据库、表格datagridview窗体显示代码实例...
- 我的第一个Python程序
- python猜猜我是几,我在python中猜数游戏的问题
- python切片读取数据_在Python中读取、切片和重组数据文件blockbyblock
- 19-7/8作业:模拟实现用户密码管理
- 山特UPS电源注意事项
- class文件与dex文件解析
- php读取写入,php操作文件(读取写入文件)
- F2FS之磁盘NAT和SIT布局及相关函数分析
- 初中生c语言入门自学视频,初中生如何学好c语言
- 如何区分电梯卡为id卡ic卡_门禁卡ID卡和IC卡从外表怎么区分?
- 我眼中的微软Azure:Microsoft Azure试用 注意
- 双系统电脑如何将两个系统安装到一个分区
- 福昕PDF阅读器:拒绝瞎忙,拥抱高效
- SAP CO11N/CO15工单报工BADI增强出口(保存前、保存后、数据验证)
- 2015年9月全国二级C语言,2015年9月全国计算机二级C语言模拟题
- Snaigt 12.4.0 的使用和Snagit KEY
- jsp连接oracle数据库并实现简单登录功能,来自网络,部分修改。(亚信联创实习)
- mysql查询1万条数据要1秒钟_SQL查询效率:100w数据查询只需要1秒钟
- DP和HDMI有什么区别?DP1.4和DP1.2线材怎么选?显示器视频带宽如何计算?
热门文章
- javq接口_Java的接口及实例
- 在IDEA中`New`没有`Mapper`文件选项(亲测)
- git commit Please tell me who you are it config --global user.email you@example.com
- MySQL前缀索引与覆盖索引:前缀索引对于索引精简 覆盖索引对于查询数据索引化
- logon oracle 密码 用户名_oracle用户名密码及用户被锁等问题
- html5中标签分为,HTML标签的三种类型
- python写数据库校验_python 验证 sqlite数据库隔离级别
- postgres 退出_如何退出postgresql
- php satellite_object_to_string,php object如何转string
- linux 卸载 flash,使用率下降到8%,Chrome 87将完全移除Flash