Flink学习（二）-- Flink安装与简单使用

妖狐艹你老母 2022-12-23 06:13 132阅读 0赞

最近在学习Flink流处理框架，自己试着在机子上部署了个flink，这里以简单的local模式为例，安装方式较为简单，仅供学习之用，正式生产上使用的话主要有standalone集群模式，Yarn模式以及k8s部署这几种模式

# 前置准备 #

*  Java 1.8.x或更高版本  
    首先确保自己机子上是否已经安装了jdk1.8或者更高版本，flink的运行是需要依赖于java环境的  
    ![在这里插入图片描述][20201122193208437.png_pic_center]

# 安装步骤 #

## 下载 ##

这里以最新的`flink-1.11.2`版本为例  
官网：[https://flink.apache.org/downloads.html][https_flink.apache.org_downloads.html]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hlM21vcmU_size_16_color_FFFFFF_t_70_pic_center]  
下载地址：

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

![在这里插入图片描述][20201122195109130.png_pic_center]

## 查看任务执行日志 ##

tail log/flink-*-taskexecutor-*.out

![在这里插入图片描述][20201122195206512.png_pic_center]

## 前端网页地址 ##

http://localhost:8081

## 停止 ##

./bin/stop-cluster.sh

[20201122193208437.png_pic_center]: /images/20221120/41741f73f3b144469d25246f9bfdb45b.png
[https_flink.apache.org_downloads.html]: https://flink.apache.org/downloads.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hlM21vcmU_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/eb22fbc5215c404f80ac0c1eba058693.png
[20201122195109130.png_pic_center]: /images/20221120/c794ee013d3f4e5e9411fda50de65aa8.png
[20201122195206512.png_pic_center]: /images/20221120/6b207fb66a254629b07a1b395a80e8ef.png