flink的安装和简单测试

时间:2019-06-09 19:19:30   收藏:0   阅读:384

一:下载安装(前提jdk安装成功)

  版本选择:1.7.2,不集成其它组件。
  下载网址:https://flink.apache.org/downloads.html
  格式:flink-1.7.2-bin-scala_2.11.tgz

  解压缩:tar -zxvf flink-1.7.2-bin-scala_2.11.tgz
  配置环境变量:cd ~
         vim .bash_profile
         export FLINK_HOME=/home/alex/soft/flink
         export PATH=$FLINK_HOME/bin:$PATH
         export PATH
         source .bash_profile

二:提交任务
  启动flink:./bin/start-cluster.sh
  查看WebUi:ip:8081,端口默认为8081

  技术分享图片  

  提交任务(socketwordcount)简单测试:
  说明:基于流式的单词统计
    1.启动9999端口
      nc -l 9999

      技术分享图片
    2.提交任务
      flink run examples/streaming/SocketWindowWordCount.jar --port 9999

  技术分享图片

     技术分享图片

 

 

原文:https://www.cnblogs.com/lyr999736/p/10994376.html

评论(0
© 2014 bubuko.com 版权所有 - 联系我们:wmxa8@hotmail.com
打开技术之扣,分享程序人生!