标签：flink v1.12 centos rwxr Flink sh games xr 501
目录
下载 Flink 安装包
https://flink.apache.org/downloads.html
链接：https://pan.baidu.com/s/1k5x_rjucs47PLBl4jAPo5g
提取码：qkph
复制这段内容后打开百度网盘手机App，操作更方便哦
安装过程
1. 为了运行Flink，只需提前安装好 Java 8 或者 Java 11
2. 解压下载好的包，并进入安装目录
$ tar -xzf flink-1.12.0-bin-scala_2.11.tgz
$ cd flink-1.12.0-bin-scala_2.11
$ ll
总用量 2092
-rw-r--r-- 1 501 games 2025120 12月 2 17:30 bash-java-utils.jar
-rwxr-xr-x 1 501 games 20216 12月 2 15:33 config.sh
-rwxr-xr-x 1 501 games 1318 6月 18 2020 find-flink-home.sh
-rwxr-xr-x 1 501 games 2377 6月 18 2020 flink
-rwxr-xr-x 1 501 games 3679 12月 2 15:33 flink-console.sh
-rwxr-xr-x 1 501 games 6569 12月 2 15:33 flink-daemon.sh
-rwxr-xr-x 1 501 games 1564 6月 18 2020 historyserver.sh
-rwxr-xr-x 1 501 games 2295 12月 2 15:33 jobmanager.sh
-rwxr-xr-x 1 501 games 1715 6月 18 2020 kubernetes-session.sh
-rwxr-xr-x 1 501 games 1133 6月 18 2020 mesos-appmaster-job.sh
-rwxr-xr-x 1 501 games 1137 6月 18 2020 mesos-appmaster.sh
-rwxr-xr-x 1 501 games 1944 12月 2 15:33 mesos-jobmanager.sh
-rwxr-xr-x 1 501 games 1889 6月 18 2020 mesos-taskmanager.sh
-rwxr-xr-x 1 501 games 2990 6月 18 2020 pyflink-shell.sh
-rwxr-xr-x 1 501 games 3738 6月 18 2020 sql-client.sh
-rwxr-xr-x 1 501 games 1973 12月 2 15:33 standalone-job.sh
-rwxr-xr-x 1 501 games 1837 8月 19 21:47 start-cluster.sh
-rwxr-xr-x 1 501 games 3310 6月 18 2020 start-scala-shell.sh
-rwxr-xr-x 1 501 games 1854 6月 18 2020 start-zookeeper-quorum.sh
-rwxr-xr-x 1 501 games 1617 8月 19 21:47 stop-cluster.sh
-rwxr-xr-x 1 501 games 1845 6月 18 2020 stop-zookeeper-quorum.sh
-rwxr-xr-x 1 501 games 3692 9月 17 23:26 taskmanager.sh
-rwxr-xr-x 1 501 games 1723 6月 18 2020 yarn-session.sh
-rwxr-xr-x 1 501 games 2281 6月 18 2020 zookeeper.sh
3. 执行 bin下的start-cluster.sh
[root@localhost flink-1.12.0]# ./bin/start-cluster.sh
Starting cluster.
[INFO] 1 instance(s) of standalonesession are already running on localhost.
Starting standalonesession daemon on host localhost.
[INFO] 1 instance(s) of taskexecutor are already running on localhost.
Starting taskexecutor daemon on host localhost.
4. Flink本地环境已启动，可以使用Flink自带的测试程序进行测试
[root@localhost flink-1.12.0]# ./bin/flink run examples/streaming/WordCount.jar
Executing WordCount example with default input data set.
Use --input to specify file input.
Printing result to stdout. Use --output to specify output path.
Job has been submitted with JobID c422aa1410f3f218a32d26d138d87246
Program execution finished
Job with JobID c422aa1410f3f218a32d26d138d87246 has finished.
Job Runtime: 137 ms
测试结果使用 tail 查看，输出了结果
[root@localhost opt]# tail -f /data10/flink/flink-1.12.0/log/flink-*-taskexecutor-*.out
==> /data10/flink/flink-1.12.0/log/flink-root-taskexecutor-0-localhost.out <==
(nymph,1)
(in,3)
(thy,1)
(orisons,1)
(be,4)
(all,2)
(my,1)
(sins,1)
(remember,1)
(d,4)
标签：flink,v1.12,centos,rwxr,Flink,sh,games,xr,501 来源： https://blog.csdn.net/baoyu_G/article/details/112385852
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。