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

     

     

  • 相关阅读:
    Linux 笔记
    查看 Linux 系统版本信息
    在网站中添加 https 百度分享
    Linux 中 Xampp 的 https 安全证书配置
    Windows 笔记
    Linux 笔记
    CentOS7 自定义登录前后欢迎信息
    构建器内部的多形性方法的行为
    编译dubbo项目方法
    《Thing in java》多态
  • 原文地址:https://www.cnblogs.com/lukairui/p/14189902.html
Copyright © 2011-2022 走看看