Flinkx-web安装

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flinkx-web安装相关的知识,希望对你有一定的参考价值。

1.Flinkx的安装

  • 1.下载源码包

Flinkx-web安装_bc

Flinkx下载地址

2.解压和安装

2.1 用解压软件进行解压即可

2.2 window环境下双击解压后的flinkx-1.8_release\\bin\\install_jars.bat

​ linux/mac环境下执行 sh install_jars.sh

本地安装db2jcc,ojdbc8,gbase,dm7的jdbc驱动的JAR包

3.编译插件

使用cmd命令进入到 flinkx-1.8_release目录,使用maven命令进行编译

mvn clean package -Dmaven.test.skip=true

Flinkx-web安装_jar_02

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服务器

Flinkx-web安装_bc_03

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安装_flink_04


以上是关于Flinkx-web安装的主要内容,如果未能解决你的问题,请参考以下文章

MySQL免安装版与安装版区别

下载完安装包怎么安装

分清全局安装与本地安装

安装一个软件提示,该安装包未包含任何证书,安装失败,怎么解决

把两个安装文件做成一个安装包,怎么做

myeclipse怎么安装怎样安装myeclipse