---
title: （SQL场景）使能OmniStream
description: "在SQL场景下，详细描述从启动Flink集群到完成OmniStream使能的操作步骤。"
url: https://www.hikunpeng.com/document/detail/zh/kunpengboostkithistory/2530/bds/kunpengbds_omniruntime_20_0925.html
sourcePath: /source/zh/kunpengboostkithistory/2530/bds/kunpengbds_omniruntime_20_0925.html
indexId: 990a22ff6db42b9b776e2a54c32f18c25771a61004f83c992ba70a50bd97502f78
---
# （SQL场景）使能OmniStream

在SQL场景下，详细描述从启动Flink集群到完成OmniStream使能的操作步骤。

1. 进入flink_jm_8c32g容器，启动Flink集群。

```
docker exec -it flink_jm_8c32g /bin/bash
source /etc/profile
cd /usr/local/flink-1.16.3/bin
./start-cluster.sh
```


  每次退出并重新进入容器后，需要执行source /etc/profile命令重新注入环境变量，避免运行任务找不到依赖组件。

2. 查看Job Manager和Task Manager是否启动成功。

  a. 在flink_jm_8c32g容器中查看是否存在StandaloneSessionClusterEntrypoint进程。

```
source /etc/profile
jps
```


    存在StandaloneSessionClusterEntrypoint进程，表示Job Manager启动成功。

  b. 分别进入flink_tm1_8c32g、flink_tm2_8c32g容器查看是否存在TaskManagerRunner进程。下述命令以flink_tm1_8c32g容器为例：

```
docker exec -it flink_tm1_8c32g /bin/bash
source /etc/profile
jps
```


    存在TaskManagerRunner进程，表示Task Manager启动成功。

3. 在flink_jm_8c32g容器中启动Nexmark。

```
docker exec -it flink_jm_8c32g /bin/bash
source /etc/profile
cd /usr/local/nexmark/bin
./setup_cluster.sh
```


4. 分别进入flink_tm1_8c32g、flink_tm2_8c32g容器查看Nexmark是否启动成功。下述命令以flink_tm1_8c32g容器为例：

```
docker exec -it flink_tm1_8c32g /bin/bash
source /etc/profile
jps
exit
```


  存在CpuMetricSender进程，表示Nexmark启动成功。

5. 在flink_jm_8c32g容器执行Nexmark用例Query0。
  1 2 3 4 5 docker exec -it flink_jm_8c32g /bin/bash source /etc/profile cd /usr/local/nexmark/bin sh run_query.sh q0 exit

  观察执行结果输出，预期结果：用例运行完成且无报错。

6. 在Task Manager所在容器上查看Flink最新的.out日志文件。
```
docker exec -it flink_tm1_8c32g /bin/bash
cd /usr/local/flink-1.16.3/log
```


  - 日志中提示“Shared Memory Metric Manager Loading Succeed!”，表示Native so库已经正常加载。
  - 日志中提示“welcome to native”，表示已经成功使能OmniStream。