Flink安装及使用
2023-09-27 14:29:10 时间
1、官网下载Flink
## 官网地址
$ https://flink.apache.org/downloads.html
## 下载地址
$ wget http://mirror.bit.edu.cn/apache/flink/flink-1.9.2/flink-1.9.2-bin-scala_2.11.tgz
文件保存在/root/soft目录下
2、安装
$ cd /root/soft
$ sudo tar -zxf flink-1.9.2-bin-scala_2.11.tgz
3、添加环境变量
$ vim /etc/profile
export FLNK_HOME=/root/soft/flink-1.9.2
export PATH=$FLINK_HOME/bin:$PATH
4、启动Flink
$ /root/soft/flink-1.9.2/bin
$ ./start-cluster.sh
$ jps
19489 jar
24595 StandaloneSessionClusterEntrypoint
25189 Jps
25039 TaskManagerRunner
可以通过观察logs目录下的日志来检测系统是否正在运行了
$ tail log/flink-*-standalonesession-*.log
JobManager同时会在8081端口上启动一个web前端,通过http://localhost:8081来访问
可以发现flink已经正常启动
5、运行示例——官方示例
使用Maven创建Flink项目,在pom.xml中添加以下依赖:
<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.9.2</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>1.9.2</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients_2.11</artifactId>
<version>1.9.2</version>
</dependency>
</dependencies>
5.1、批处理运行WordCount
可以直接在/root/soft/flink-1.9.2/examples/batch中运行WordCount程序,并且这里还有更多示例:
$ cd /root/soft/flink-1.9.2/examples/batch
$ /root/soft/flink-1.9.2/bin/flink run WordCount.jar
相关文章
- 如何在 Ubuntu 11.04 (Natty) 下以 PPA 方式安装 Gyachi
- CentOS7.4安装部署KVM虚拟机
- CentOS7 linux下yum安装redis以及使用
- Eclipse安装Groovy插件
- Brew 卸载MySql以及安装Mysql
- Memcached 笔记与总结(1)Linux(CentOS 6.6) 和 Windows(7)下安装与配置 Memcached (1.4.24)与 Memcached 基础命令
- thinkpad的E480安装ubuntu后wifi无法使用问题解决
- linux下rocksdb的编译安装
- App测试从入门到精通之安装、卸载和运行测试
- CentOS 5 64bit 编译安装MySQL报错
- centos7下安装nginx(转)
- Linux之JDK1.8的安装
- pip安装selenium报错:Read timed out
- BinDiff安装教程(v4.3)