zoukankan      html  css  js  c++  java
  • Flink安装极简教程-单机版

    一:安装

    Flink官网下载地址:https://flink.apache.org/downloads.html

    选择1.6.3版本

     下载:

    wget http://mirrors.hust.edu.cn/apache/flink/flink-1.7.1/flink-1.7.1-bin-hadoop26-scala_2.11.tgz

    解压:

    tar -zxvf flink-1.6.3-bin-hadoop26-scala_2.11.tgz
    mv  flink-1.6.3 flink

    查看本机host

    进入flink目录,修改conf/flink-conf.yaml文件

    vim  conf/flink-conf.yaml

    修改conf/masters文件,修改后内容如下:

    启动单机版flink:

    bin/start-cluster.sh

    启动界面如下:

    查看启动是否成功:

     查看dashboard界面:http://192.168.186.129:808

     

    二:官方案例演示

    1.启动一个终端输入如下指令:

    nc -lk 8000

    2.启动第二个终端,执行flink自带的wordcount案例

    bin/flink run examples/streaming/SocketWindowWordCount.jar --port 8000

    3.在第一个终端发送数据:

    4.测试结果保存在log/flink-root-taskexecutor-0-woniu.out文件中

    5. Dashboard也可以看到任务信息

     

  • 相关阅读:
    poj 2391 Ombrophobic Bovines
    混合欧拉回路poj 1637 Sightseeing tour
    POJ1149-PIGS
    C
    B
    A
    C
    B
    A
    O
  • 原文地址:https://www.cnblogs.com/woniu201/p/10334277.html
Copyright © 2011-2022 走看看