鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

SQL使能特性

  1. 进入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
  2. 查看JobManager和TaskManager是否启动成功。
    1. 在flink_jm_8c32g容器中查看是否存在StandaloneSessionClusterEntrypoint进程。
      source /etc/profile
      jps

    2. 分别进入flink_tm1_8c32g、flink_tm2_8c32g容器查看是否存在TaskManagerRunner进程,下面以flink_tm1_8c32g容器为例:
      docker exec -it flink_tm1_8c32g /bin/bash
      source /etc/profile
      jps

  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是否启动成功,存在CpuMetricSender进程证明启动成功。
    docker exec -it flink_tm1_8c32g /bin/bash
    source /etc/profile
    jps
    exit

  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
    
    图1 Query0执行结果
  6. 在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 日志输出