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

     

     

  • 相关阅读:
    JDK源码阅读--AbstractStringBuilder
    JDK源码阅读--String
    JDK源码阅读--Object
    linux查看日志
    velocity 相关
    oracle Trigger
    ssm调用后台oracle存储过程统计分析数据
    oracle 优化相关
    synchronized 控制并发(活动秒杀)
    SpringBoot自动装配的原理
  • 原文地址:https://www.cnblogs.com/lukairui/p/14189902.html
Copyright © 2011-2022 走看看