Flink初体验

Posted 她说:斯文败类

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink初体验相关的知识,希望对你有一定的参考价值。

软件安装版本号说明:

JDK:1.8.0_302

Flink:flink-1.14.2-bin-scala_2.11

linux:CentOS 7.0

一、安装

1.官网下载(https://flink.apache.org/downloads.html) Apache Flink 1.14.2 for Scala 2.11版本

2.上传至服务器并解压文件

tar -xvf flink-1.14.2-bin-scala_2.11.tgz

3.启动Flink

cd $FLINK_HOME
./bin/start-cluster.sh Starting cluster

进入flink下bin目录执行start-cluster.sh脚本启动Flink(暂不用修改配置)

二、初体验

1.在浏览器键入http://ip:8081 进入Flink Web UI

 2.在Flink 1.14.2 二进制发布包中官方已经提供了部分demo供用户测试和体验,我们可以在flink目录下examples中找到。本次体验使用经典、简单的WordCount.jar

 3.运行测试示例

cd $FLINK_HOME
/bin/flink run ./examples/streaming/WordCount.jar

4.检查Flink Web UI "Job -> Runing Jobs"中的作业

5.如果应用是流式的,它会一直运行下去,直到你手动取消。取消的方式是在UI中选定作业,然后点击Cancel按钮。

6.如果作业是批量的,在作业结束后作业状态更改为FINISHED,可以在Flink Web UI "Job -> Completed Jobs"中查看。

 7.关闭Flink服务

cd $FLINK_HOME
./bin/stop-cluster.sh

       未完待续...

以上是关于Flink初体验的主要内容,如果未能解决你的问题,请参考以下文章

[SakuraiYo][软工作业]用户体验分析:以 “师路南通网站” 为例

pymongo初体验及插入性能测试

WordCount-软件测试初体验

Jira测试管理插件初体验

LevelDB初体验测试

FlashCache初体验