安装OmniStream

在Flink独立部署模式中，可以通过安装预先编译好的OmniStream Flink Native化二进制包，将其以插件的形式集成到Flink中。

1. 在物理机上创建目录“/usr/local/OmniStream”，用于存放OmniStream Flink Native化的二进制文件。
   将从表3中获取的BoostKit-omnistream_1.1.0.zip安装包解压到“/usr/local/OmniStream”目录下。

   1 2 3 4

   unzip BoostKit-omnistream_1.1.0.zip mkdir -p /usr/local/OmniStream cp -r OmniStream_Default/* /usr/local/OmniStream/ chmod -R 550 /usr/local/OmniStream/*

2. 查看解压文件。

   1

   ls

   解压二进制包后主要得到如下JAR包、so文件和基础库、头文件目录include。

   1 2 3 4 5 6 7 8

   flink-tnel-0.1-SNAPSHOT.jar libtnel.so libboundscheck.so libboostkit-omniop-codegen-2.0.0-aarch64.so libboostkit-omniop-operator-2.0.0-aarch64.so libboostkit-omniop-vector-2.0.0-aarch64.so libbasictypes include

3. 编辑Flink的配置文件“/usr/local/flink/bin/config.sh”。
   1. 打开文件。

      1	vi /usr/local/flink/bin/config.sh

   2. 按“i”进入编辑模式，找到constructFlinkClassPath()函数，注释掉原有的echo行，并添加新的PATCH路径。

      1 2 3

      # echo "$FLINK_CLASSPATH""$FLINK_DIST" PATCH=/usr/local/OmniStream/flink-tnel-0.1-SNAPSHOT.jar echo $PATCH:"$FLINK_CLASSPATH""$FLINK_DIST"

      修改后的配置文件如下图。

      

   3. 按“Esc”键，输入:wq!，按“Enter”保存并退出编辑。
4. 编辑Flink的配置文件“/usr/local/flink/conf/flink-conf.yaml”。
   1. 打开文件。

      1	vi /usr/local/flink/conf/flink-conf.yaml

   2. 按“i”进入编辑模式，添加libtnel.so文件所在的路径到env.java.opts中，即2中解压后so文件所在的目录。

      1	env.java.opts: -Djava.library.path=/usr/local/OmniStream/

   3. 按“Esc”键，输入:wq!，按“Enter”保存并退出编辑。