安装OmniStream

安装OmniStream Flink Native化二进制包

在Flink独立部署模式下，将OmniStream Flink Native化所需的二进制包进行安装部署，支持配置形式的插件化部署。

1. 在物理机新建目录“/usr/local/OmniStream”将表3获取的BoostKit-omniStream_1.0.0.zip安装包解压到“/usr/local/OmniStream”目录下。

   1 2 3 4

   unzip BoostKit-omnistream_1.0.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 9 10 11

   flink-tnel-0.1-SNAPSHOT.jar omni-flink-table-planner.jar omni-table-planer-0.1-SNAPSHOT.jar original-flink-tnel-0.1-SNAPSHOT.jar libtnel.so libsecurec.so libboostkit-omniop-codegen-1.8.0-aarch64.so libboostkit-omniop-operator-1.8.0-aarch64.so libboostkit-omniop-vector-1.8.0-aarch64.so libbasictypes include

3. 在“/usr/local/flink/bin/config.sh”文件中更新配置内容。
   1. 打开“/usr/local/flink/bin/config.sh”文件。

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

   2. 按“i”进入编辑模式，新增lib加载路径；修改constructFlinkClassPath()，注释掉原生echo行，新增新的PATCH加载路径。

      1 2 3

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

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

      

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

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

   2. 按“i”进入编辑模式，添加libtnel.so文件配置，即2中解压后so文件所在的目录。

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

   3. 按“Esc”键，输入:wq!，按“Enter”保存并退出编辑。
5. 若需要使用OmniStateStore作为状态后端，参考启动OmniStateStore进行配置