StandaloneHA集群测试

• node4上链接zk客户端

  xxxxxxxxxx
  [root@node4 ~]# zkCli.sh
  [zk: localhost:2181(CONNECTED) 7] get -s /flink/cluster_standalone_ha/leader/resource_manager/connection_info
  ��w97akka.tcp://flink@node1:36856/user/rpc/resourcemanager_0srjava.util.UUID����m�/J
  

• node1上停止JobManager

  xxxxxxxxxx
  [root@node1 ~]# /opt/flink-salone-ha/bin/jobmanager.sh stop
  Stopping standalonesession daemon (pid: 12990) on host node1.
  

• node4上zk查询，发现Active节点改变

  xxxxxxxxxx
  [zk: localhost:2181(CONNECTED) 9] get -s /flink/cluster_standalone_ha/leader/resource_manager/connection_info
  ��w97akka.tcp://flink@node2:41722/user/rpc/resourcemanager_0srjava.util.UUID����m�/J
  

• node1上启动JobManager

  xxxxxxxxxx
  [root@node1 ~]# /opt/flink-salone-ha/bin/jobmanager.sh start
  Starting standalonesession daemon on host node1.
  

• node4上zk查询，由于node2正常运行，所以修复好node1后，Active节点不变。

  xxxxxxxxxx
  [zk: localhost:2181(CONNECTED) 9] get -s /flink/cluster_standalone_ha/leader/resource_manager/connection_info
  ��w97akka.tcp://flink@node2:41722/user/rpc/resourcemanager_0srjava.util.UUID����m�/J
  

• 将开发的WordCount项目编译打包

  

• node3上监听8888端口

  xxxxxxxxxx
  [root@node3 ~]# nc -lk 8888
  

• 上传作业

  

• 配置执行类

  

• 提交作业

  

• node3上输入信息

  xxxxxxxxxx
  [root@node3 ~]# nc -lk 8888
  a b c
  a b d
  a b c
  a d d
  

• 查看作业相关信息

  

• 查看执行的TaskManager

  

• 点击LOG查看日志和输出结果