构建Flink第一个应用程序
Posted @SmartSi
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了构建Flink第一个应用程序相关的知识,希望对你有一定的参考价值。
1. 环境搭建
Flink 可以运行在 Linux、Mac 以及 Windows 上。在这我们使用的是 Mac 系统。为了开发 Flink 应用程序,需要提前安装 Java 和 Maven 环境。
如果已经安装 Java 环境,运行如下命令会输出具体的版本信息:
wy:flink wy$ java -version
java version "1.8.0_161"
Java(TM) SE Runtime Environment (build 1.8.0_161-b12)
Java HotSpot(TM) 64-Bit Server VM (build 25.161-b12, mixed mode)
如果已经安装 Maven 环境,运行如下命令会输出具体版本信息:
wy:flink wy$ mvn --version
Apache Maven 3.5.4 (1edded0938998edf8bf061f1ceb3cfdeccf443fe; 2018-06-18T02:33:14+08:00)
Maven home: /opt/maven
Java version: 1.8.0_161, vendor: Oracle Corporation, runtime: /Library/Java/JavaVirtualMachines/jdk1.8.0_161.jdk/Contents/Home/jre
Default locale: zh_CN, platform encoding: UTF-8
OS name: "mac os x", version: "10.12.6", arch: "x86_64", family: "mac"
在搭建好我们的依赖环境之后,最重要的是搭建我们的 Flink 集群,具体可以参考
以上是关于构建Flink第一个应用程序的主要内容,如果未能解决你的问题,请参考以下文章
Flink 1.14 Table & SQL 第一个程序 WordCount