flink 可以运行在 Linux, Mac OS X, and Windows 操作系统上面。要运行Flink得先安装JDK 8.X。

JDK安装参看:http://www.itclj.com/blog/5920236681c06e672f942ad4

下载

官网下载地址:https://flink.apache.org/zh/downloads.html

GIThub源码下载地址:https://github.com/apache/flink

百度盘:https://pan.baidu.com/s/1rGSebFtOiRupsgirHDjmiA 提取码:l75y

当前最新稳定版本是1.8.1

在这里插入图片描述

下载的文件:flink-1.8.1-bin-scala_2.12.tgz

启动

把下载的文件解压到一个目录,例如我本地解压到了

D:\bigdata\flink

解压后的目录结构如下

在这里插入图片描述

window命令行下进入目录D:\bigdata\flink\flink-1.8.1运行

./bin/start-cluster.bat

启动flink

在这里插入图片描述

Flink启动后,会有一个WEB的管理页面,默认地址为:

http://localhost:8081/.

在这里插入图片描述

这样,flink就算已经启动好了。

运行demo

flink 提供两种任务运行入口

  • 1、flink.bat脚本启动任务程序
  • 2、页面上传任务程序包运行
通过脚本启动任务

运行字统计任务demo程序

flink.bat run ../examples/batch/WordCount.jar

在这里插入图片描述

可以看到统计结果直接打印到了控制台上。

通过页面上传任务程序包运行

上传任务程序包

在这里插入图片描述

运行任务程序包
在这里插入图片描述

任务管理监控
在这里插入图片描述

Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐