快速上手

源码编译

依赖组件

软件	版本
GCC	10.3.1
CMake	3.22.0
JDK	1.8.0_342
zlib	1.2.8
LLVM	12.0.1
googletest	1.10.0
jemalloc	5.2.1
nlohmann json	3.11.3
libboundscheck	V1.1.16
OmniOperator	20250630
snappy	1.1.10
rocksdb	8.11.4
BoostKit-kaccjson	1.0.0
BoostKit-ksl	2.5.1

编译命令

编译OmniStream前需要编译OmniAdaptor代码，编译命令如下。

mkdir -p /opt/build && cd /opt/build
cd omnistream/omniop-flink-extension/omni-flink-bundle
mvn clean package -DskipTests

OmniStream编译命令如下。

cd /opt/build/OmniStream/cpp
mkdir build
cd build
cmake ..
make install -j$PARALLELISM

说明： $PARALLELISM表示编译指定并行度。

环境部署

环境部署的详细操作步骤请参见安装指南。

测试验证

进入Flink安装目录下的bin目录，并启动Flink。
```
cd $FLINK_HOME/bin/ && ./start-cluster.sh
```
启动sql-client后，进行测试。
```
./sql-client.sh
```
在命令行中输入以下内容。
```
SELECT 'Hello, Flink!';
```
可以正常输出结果即安装正常。

免责声明

此代码仓计划参与Flink软件开源，仅作Flink功能扩展/Flink性能提升，编码风格遵照原生开源软件，继承原生开源软件安全设计，不破坏原生开源软件设计及编码风格和方式，软件的任何漏洞与安全问题，均由相应的上游社区根据其漏洞和安全响应机制解决。请密切关注上游社区发布的通知和版本更新。鲲鹏计算社区对软件的漏洞及安全问题不承担任何责任。