Flink学习(二)-- Flink安装与简单使用
最近在学习Flink流处理框架,自己试着在机子上部署了个flink,这里以简单的local模式为例,安装方式较为简单,仅供学习之用,正式生产上使用的话主要有standalone集群模式,Yarn模式以及k8s部署这几种模式前置准备Java 1.8.x或更高版本首先确保自己机子上是否已经安装了jdk1.8或者更高版本,flink的运行是需要依赖于java环境的安装步骤下载这里以最新的flink-1.
·
最近在学习Flink流处理框架,自己试着在机子上部署了个flink,这里以简单的local模式为例,安装方式较为简单,仅供学习之用,正式生产上使用的话主要有standalone集群模式,Yarn模式以及k8s部署这几种模式
前置准备
- Java 1.8.x或更高版本
首先确保自己机子上是否已经安装了jdk1.8或者更高版本,flink的运行是需要依赖于java环境的
安装步骤
下载
这里以最新的flink-1.11.2
版本为例
官网:https://flink.apache.org/downloads.html
下载地址:
wget https://mirrors.bfsu.edu.cn/apache/flink/flink-1.11.2/flink-1.11.2-bin-scala_2.12.tgz
解压
tar -zxf flink-1.11.2-bin-scala_2.12.tgz
启动
#进入目录
cd flink-1.11.2/
# 启动脚本
./bin/start-cluster.sh
提交样例任务
./bin/flink run examples/streaming/WordCount.jar
查看任务执行日志
tail log/flink-*-taskexecutor-*.out
前端网页地址
http://localhost:8081
停止
./bin/stop-cluster.sh
更多推荐
已为社区贡献1条内容
所有评论(0)