flink开发教程_flink环境搭建

flink开发教程_flink环境搭建本篇文章主要介绍flink的部署一、部署1、下载安装flink安装包 这里用的是1.15.1版本,下载地址:https://www.apache

大家好,欢迎来到IT知识分享网。

本篇文章主要介绍flink的部署

一、部署

1、下载安装flink安装包 这里用的是1.15.1版本,下载地址:

https://www.apache.org/dyn/closer.lua/flink/flink-1.15.1/flink-1.15.1-bin-scala_2.12.tgz

2、解压安装包

tar -zxvf flink-1.15.1-bin-scala_2.12.tgz

3、启动flink集群

cd flink-1.15.1 & ./bin/start-cluster.sh

启动成功会显示日志如下:

Starting cluster.
Starting standalonesession daemon on host macBook-Pro-2.local.
Starting taskexecutor daemon on host macBook-Pro-2.local.

IT知识分享网

3、访问管理界面

localhost:8081

flink开发教程_flink环境搭建

运行界面

4、测试使用

根据提供的案例里词频统计 ,执行如下命令:

IT知识分享网./bin/flink run ./examples/batch/WordCount.jar

在completed jobs就能看到一条执行记录

整体的执行经过过程如下:

flink开发教程_flink环境搭建

执行

4、停止集群

./bin/stop-cluster.sh

免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/6287.html

(0)
上一篇 2022-12-14 22:56
下一篇 2022-12-14 23:00

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注

关注微信