下载
以下为flink1.9的下载地址(目前最新,之后如果有更新还请访问官网下载)
scala 2.11版本
scala2.22版本
以上两个tgz包默认不包含hdfs/hbase等的依赖,如果有需要还需要下载以下依赖包
hadoop2.7.5依赖 (hadoop 2.7.5,其他版本请访问官网) 下载完了之后需要将此jar放到 flink的lib文件夹中
环境说明(每个节点)
java1.8+
必须要有ssh
部署
tar xzf flink-*.tgz
cd flink-*
配置开始测试的时候用默认的就好,如果是生产环境还是是要参考配置详单
启动
bin/start-cluster.sh
访问
测试
启动一个nc窗口指定端口9000
nc -l 9000
提交flink任务
./bin/flink run examples/streaming/SocketWindowWordCount.jar--port 9000
监控结果文件
tail -f log/flink-*-taskexecutor-*.out