flink安装与基础测试

1.下载flink-1.13.6-bin-scala_2.11.tgz

2.tar -xzvf /mnt/d/bigdata/targz/flink-1.14.3-bin-scala_2.11.tgz

为了方便将解压后的文件夹名称改为flink

3.下载完成后修改flink目录的所属用户和所属组,防止出现could not start the JobMaster问题
sudo chown -R root:root /usr/local/flink

4.进入到bin目录执行
./start-cluster.sh

5.使用jps查询flink是否正常启动

6.可以在浏览器输入 localhost:8081 以访问其 web UI 界面。
在这里插入图片描述

7.提交测试案例,测试flink是否运行正常
执行如下命令以执行 WordCount 程序：

./bin/flink run examples/streaming/WordCount.jar