最近在学习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
Logo

K8S/Kubernetes社区为您提供最前沿的新闻资讯和知识内容

更多推荐