---
title: 安装OmniStream
description: "在Flink独立部署模式中，可以通过安装预先编译好的OmniStream Flink Native化二进制包，将其以插件的形式集成到Flink中。"
url: https://www.hikunpeng.com/document/detail/zh/kunpengboostkithistory/2530/bds/kunpengbds_omniruntime_20_09018.html
sourcePath: /source/zh/kunpengboostkithistory/2530/bds/kunpengbds_omniruntime_20_09018.html
indexId: 3eda9dfb3002c87d96fc085d220baed46b2726d7fb41cbbe0bce5bd79ddad67179
---
# 安装OmniStream

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

1. 在物理机上创建目录“/usr/local/OmniStream”，用于存放OmniStream Flink Native化的二进制文件。
  将从表3中获取的BoostKit-omniruntime-omnistream-1.1.0.zip安装包解压到“/usr/local/OmniStream”目录下。 1 2 3 4 unzip BoostKit-omniruntime-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”。

  a. 打开文件。
    1 vi /usr/local/flink/bin/config.sh

  b. 按“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"

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

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

  a. 打开文件。
    1 vi /usr/local/flink/conf/flink-conf.yaml

  b. 按“i”进入编辑模式，添加libtnel.so文件所在的路径到env.java.opts中，即    2
中解压后so文件所在的目录。
    1 env.java.opts: -Djava.library.path=/usr/local/OmniStream/

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