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

     

     

  • 相关阅读:
    文件光标移动
    python的版本的差别 "2","3"
    java通过jdbc操作Excel
    qt通过odbc操作Excel
    qt读取oracle表数据
    virtual box安装oracle_rac_10g
    oracle rac +standby
    rac不完全恢复
    rac完全恢复学习
    oracle rac搭建(三)--安装中的问题
  • 原文地址:https://www.cnblogs.com/lukairui/p/14189902.html
Copyright © 2011-2022 走看看