SQL使能特性
- 进入flink_jm_8c32g容器,集群模式启动JobManager和TaskManager,每次重新进入容器后需要执行source /etc/profile命令。
docker exec -it flink_jm_8c32g /bin/bash source /etc/profile cd /usr/local/flink-1.16.3/bin ./start-cluster.sh
- 查看JobManager和TaskManager是否启动成功。
- 在flink_jm_8c32g容器中查看是否存在StandaloneSessionClusterEntrypoint进程。
source /etc/profile jps
- 分别进入flink_tm1_8c32g、flink_tm2_8c32g容器查看是否存在TaskManagerRunner进程,下面以flink_tm1_8c32g容器为例:
docker exec -it flink_tm1_8c32g /bin/bash source /etc/profile jps
- 在flink_jm_8c32g容器中查看是否存在StandaloneSessionClusterEntrypoint进程。
- 在flink_jm_8c32g容器中启动Nexmark。
docker exec -it flink_jm_8c32g /bin/bash source /etc/profile cd /usr/local/nexmark/bin ./setup_cluster.sh
- 分别进入flink_tm1_8c32g、flink_tm2_8c32g容器查看Nexmark是否启动成功,存在CpuMetricSender进程证明启动成功。
docker exec -it flink_tm1_8c32g /bin/bash source /etc/profile jps exit
- 在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
图1 Query0执行结果 - 在TaskManager所在容器上查看Flink最新.out日志,日志中有“Loading Task Native Execution Library”日志输出说明Native so库已经正常加载。日志中有“welcome to native”日志输出,证明OmniStream Flink Native化特性已使能。
1 2
docker exec -it flink_tm1_8c32g /bin/bash cd /usr/local/flink-1.16.3/log
图2 日志输出
父主题: 使用特性