快速入门
编译构建
1. 编译依赖
| 硬件依赖 | |
|---|---|
| CPU | Kunpeng-920 / Kunpeng-920B |
| Architecture | aarch64 |
| 内存 | 32GB及以上 |
| 软件依赖 | 软件版本 |
|---|---|
| 操作系统 | Kunpeng-920 / Kunpeng-920B |
| CMake | 3.22.0 |
| GCC | 10.3.1 |
| JDK | 1.8.0_432 |
2. 源码编译
-
下载源代码: 从OpenEuler开源社区下载OmniStateStore的源代码到编译服务器上;
-
执行编译命令,以编译release包为例:
bash scripts/build.sh -t release其它编译选项如下表所示,不同的编译选项可以组合使用。
编译参数 编译选项 简要说明 -t debug/release 编译debug/release包 --ut - 编译UT测试程序 --sve - 使能鲲鹏高性能SVE指令 -h - 帮助 -
检查编译成功的软件包。 编译成功则在目录dist/下存在: OmniStateStore软件包BoostKit-omnistatestore_1.x.x_aarch64_xxx.tar.gz。
3. 开发者测试
-
执行测试运行脚本。
sh test/run_dt.sh -
执行测试运行脚本后会自动编译和测试用例执行,最后观测测试用例执行结果即可。
环境部署
环境部署参考以下链接 installation_guide.md
测试验证
-
进入Flink安装目录下的bin目录,并启动Flink。
cd $FLINK_HOME/bin/ && ./start-cluster.sh -
执行“${FLINK_HOME}/examples/streaming/WordCount.jar”示例程序。
$FLINK_HOME/bin/flink run $FLINK_HOME/examples/streaming/WordCount.jar观察到Task Manager日志中打印“OmniStateStore service start success.”,说明OmniStateStore启动成功。