Flink-v1.12官方网站翻译-P001-Local Installation

 

 

 

按照以下几个步骤下载最新的稳定版本并开始使用。

 

第一步:下载

为了能够运行Flink,唯一的要求是安装了一个有效的Java 8或11。你可以通过以下命令检查Java的正确安装。

java -version

下载1.12.0版本,并解压。

$ tar -xzf flink-1.12.0-bin-scala_2.11.tgz
$ cd flink-1.12.0-bin-scala_2.11

第二步:启动群集

Flink通过一个bash脚本来启动一个本地集群。

$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host.
Starting taskexecutor daemon on host.

第三步:提交作业

Flink的各版本都带有一些示例Job。您可以快速地将这些应用程序中的一个部署到正在运行的集群中。

$ ./bin/flink run examples/streaming/WordCount.jar
$ tail log/flink-*-taskexecutor-*.out
  (to,1)
  (be,1)
  (or,1)
  (not,1)
  (to,2)
  (be,2)

此外,你可以查看Flink的Web UI来监控Cluster和运行Job的状态。

第四步:停止群组 

当你完成后,你可以快速停止集群和所有运行的组件。

 

$ ./bin/stop-cluster.sh

 

 

 

相关文章:

  • 2022-02-15
  • 2021-08-15
  • 2021-08-08
  • 2021-12-09
  • 2022-02-23
  • 2021-12-29
  • 2021-12-17
  • 2021-10-12
猜你喜欢
  • 2021-10-24
  • 2021-08-10
  • 2021-11-24
  • 2021-08-28
  • 2022-03-03
  • 2022-01-01
  • 2021-05-18
相关资源
相似解决方案