zoukankan      html  css  js  c++  java
  • 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

     

     

  • 相关阅读:
    hdu 5116 计数
    hdu 5117 数学公式展开 + dp
    hdu 5115 Dire Wolf 区间dp
    I00025 寻找循环数
    外部设备发展趋势
    外部设备发展趋势
    互联网
    互联网
    I00024 出钱买羽
    I00024 出钱买羽
  • 原文地址:https://www.cnblogs.com/lukairui/p/14189902.html
Copyright © 2011-2022 走看看