（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是否启动成功。
   1. 在flink_jm_8c32g容器中查看是否存在StandaloneSessionClusterEntrypoint进程。

      source /etc/profile
      jps

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

      

   2. 分别进入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日志文件。

   1 2	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。