在HA环境下提交任务与standalone单节点模式下是一样的,即使JobManager所在服务器宕机也没有关系,JobManager会自动切换。
在node01上执行以下命令启动Socket服务,输入单词。
启动Flink自带的单词统计程序,接收输入的Socket数据并进行统计。
执行以下命令查看统计结果。