flink安装与基础测试_flink 测试

作者：神奇cpp | 2024-07-24 19:12:53

踩

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

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/神奇cpp/article/detail/876363