InstallFlinkx.md

1.Flinkx的安装

• 1.下载源码包

  

  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
  

  

• 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 
  

2.如何在standalone上提交任务？

前置条件: flink1.8版本，高版本目前不支持

解释: $FLINK_HOME 安装Flink的目录

1.启动flink

$FLINK_HOME/bin/start-cluster.sh

2.执行如下命令

./bin/flinkx -mode standalone \
             -job ./job/stream.json \
             -flinkconf $FLINK_HOME/conf

3.演示结果如下