\1.下载地址
https://flink.apache.org
or 直接找tgz
https://www.apache.org/dyn/closer.lua/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.11.tgz
\2.解压到/usr/flink下
\3.启动

/usr/flink/bin$ ./start-cluster.sh 

\4.jps查看

9330 StandaloneSessionClusterEntrypoint
9749 Jps
9641 TaskManagerRunner

\5.测试词频统计
/usr/flink/in.txt 是自己创建的输入文件,/usr/flink/out.txt是输出文件

root@cold-ThinkStation-P300:/usr/flink# bin/flink  run /usr/flink/examples/batch/WordCount.jar --input /usr/flink/in.txt --output /usr/flink/out.txt
Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐