1、安装nc
下载http://vault.centos.org/6.4/os/x86_64/Packages/nc-1.84-22.el6.x86_64.rpm
执行命令:rpm -iUv nc-1.84-22.el6.x86_64.rpm
2、下载对应版本的Flink
http://flink.apache.org/downloads.html
tar -zxvf flink-1.3.2-bin-hadoop27-scala_2.10.tgz -C /opt
解压后启动即可!
3.修改配置文件
1)conf/flink-conf.yaml
jobmanager.rpc.address: 192.168.128.146
2) conf/ 下 有 masters slaves
masters是配置JobManager HA 的,在这里不需要配置
slaves配置工作节点 TaskManager
4.启动
bin/start-cluster.sh
http://192.168.128.146:8081
5.日志查看
在对应安装目录的log下
6.测试
使用自带的测试样例
bin/flink run examples/streaming/SocketWindowWordCount.jar --port 9000
批处理样例:
./bin/flink run ./examples/batch/WordCount.jar
文献;