Flinkx-web安装
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flinkx-web安装相关的知识,希望对你有一定的参考价值。
1.Flinkx的安装
- 1.下载源码包
2.解压和安装
2.1 用解压软件进行解压即可
2.2 window环境下双击解压后的flinkx-1.8_release\\bin\\install_jars.bat
linux/mac环境下执行 sh install_jars.sh
3.编译插件
使用cmd命令进入到 flinkx-1.8_release目录,使用maven命令进行编译
mvn clean package -Dmaven.test.skip=true
4.配置文件
4.1 flinkx-1.8_release\\flinkconf目录下flink-conf.yaml里添加如下:
rest.bind-port: 8888
4.2 flinkx-1.8_release\\下面创建job目录
4.3 在 flinkx-1.8_release\\job目录下面添加stream.json
"job" :
"content" : [
"reader":
"name": "streamreader",
"parameter":
"column": [
"name": "id",
"type": "int"
,
"name": "name",
"type": "string"
]
,
"writer" :
"parameter" :
"print": false
,
"name" : "streamwriter"
],
"setting" :
"restore" :
"isRestore" : false,
"isStream" : false
,
"errorLimit" :
,
"speed" :
"bytes" : 0,
"channel" : 1,
"rebalance" : true
4.4将图中所选择的文件上传到Linux服务器
4.5编写启动脚本start.sh文件
sh ./bin/flinkx-job ./job/stream.json -flinkconf ./flinkconf/ -pluginRoot ./plugins/
5.执行任务:
[root@mini4 hadoop]# tar -zxvf flinkx-1.8_release.tar.gz
[root@mini4 flinkx-1.8_release]# sh start.sh
演示结果如下
以上是关于Flinkx-web安装的主要内容,如果未能解决你的问题,请参考以下文章