构建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

Flink 1.14 Table & SQL 第一个程序 WordCount

Flink 系统性学习笔记系列

Apache Flink 入门示例demo

Flink从入门到精通系列文章

如何进行Flink项目构建,快速开发Flink应用程序?