flink的安装和简单测试


一:下载安装(前提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

  

     

 

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM