zoukankan      html  css  js  c++  java
  • Apache Flink快速入门-本地快速安装

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

    第 1 步:下载 

    为了能够运行 Flink,唯一的要求是安装了Java 8 或 11您可以通过发出以下命令来检查 Java 的正确安装:

    java -version
    

    下载1.13.0 版本并解压缩它。

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

    第 2 步:启动集群 

    Flink 附带一个 bash 脚本来启动本地集群。

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

    第 3 步:提交作业 

    Flink 的发布附带了许多示例作业。您可以将这些应用程序之一快速部署到正在运行的集群中。

    $ ./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来监控集群和运行作业的状态。

    第 4 步:停止集群 

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

    $ ./bin/stop-cluster.sh
  • 相关阅读:
    AcWing 276. I-区域
    学习笔记:可持久化线段树(主席树):静态 + 动态
    NOIP2016提高组 天天爱跑步
    AcWing 195. 骑士精神
    标准文档流
    css 盒模型
    css 继承性和层叠性
    css 选择器
    css 引入方式
    html body中的标签2
  • 原文地址:https://www.cnblogs.com/BlogNetSpace/p/15119834.html
Copyright © 2011-2022 走看看