Installing OmniStream

In independent deployment mode, you can install the precompiled OmniStream binary package and integrate it into Flink as a plugin.

1. Create the /usr/local/OmniStream directory on the physical machine to store OmniStream binary files.
   Extract the BoostKit-omniruntime-omnistream-1.1.0.zip installation package obtained from Table 3 to the /usr/local/OmniStream directory.

   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. Check the extracted files.

   1

   ls

   After the binary package is extracted, the JAR package, SO files, basic library, and include directory are obtained.

   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. Edit the Flink configuration file /usr/local/flink/bin/config.sh.
   1. Open the file.

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

   2. Press i to enter the insert mode, find the constructFlinkClassPath() function, comment out the echo line, and add a new PATCH path.

      1 2 3

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

      The updated configuration file is as follows:

      

   3. Press Esc, type :wq!, and press Enter to save the file and exit.
4. Edit the Flink configuration file /usr/local/flink/conf/flink-conf.yaml.
   1. Open the file.

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

   2. Press i to enter the insert mode. In env.java.opts, add the libtnel.so file path, that is, the path to the .so files extracted in 2.

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

   3. Press Esc, type :wq!, and press Enter to save the file and exit.