zoukankan      html  css  js  c++  java
  • Linux安装flink

    一、下载Flink(2种方式为了简单我用第二种。)

    1、手动下载Flink

    1.1、官网下载:https://flink.apache.org/downloads.html#apache-flink-172

    file

    1.2、下载压缩包 上传服务器自己创建的目录(略)。

    2、自动下载Flink

    file

    创建目录: mkdir /root/kingyifan/flink
    下载Flink: wget mirrors.hust.edu.cn/apache/flink/flink-1.7.2/flink-1.7.2-bin-hadoop24-scala_2.11.tgz(版本号请访问网站自行查询)
    

    具体版本号请查阅:http://mirrors.hust.edu.cn/apache/flink/

    file

    二、解压压缩包

    file

    命令:tar -zxvf flink-1.7.2-bin-hadoop24-scala_2.11.tgz 
    

    解压成功:

    file

    三、启动Flink

    file

    进入bin目录:cd /root/kingyifan/flink/flink-1.7.2/bin/
    启动flink:./start-cluster.sh
    

    查看是否启动成功:

    file

     命令:jps
    

    三、centos6开放flink默认端口(8081) 修改iptables

    file

    进入配置iptables:vi /etc/sysconfig/iptables
    增加:-A INPUT -m state --state NEW -m tcp -p tcp --dport 8081 -j ACCEPT
    

    重启防火墙:service iptables restart

    file

    四、访问ui界面:192.168.241.134:8081

    file

    五、测试 5.1 先xsheel复制三个会话:

    file

    打开第一个会话:

    file

    启动一个终端(端口随意):nc -lk 8888 
    

    打开第二个会话:

    file

    进入bin目录:cd /root/kingyifan/flink/flink-1.7.2/
    命令:bin/flink run examples/streaming/SocketWindowWordCount.jar --port 8888
    

    打开第三个会话:

    file

    进入log目录:cd /root/kingyifan/flink/flink-1.7.2/log
    命令:tail -f flink-root-taskexecutor-5-localhost.localdomain.out(不一定是这个日志文件)
    

    日志目录:

    file

    在第一个会话随便输入内容

    file

    看第三个内容:

    file

    有没有一个疑惑 后面的1是个什么?

    他在几算多少秒内出现了多少次 我们随便输几个1测试一下

    file

    发现他已经几算出来了。

    file

    我们也可以看一下Running Jobs

    file

    终、、


    以上linux安装以及部署flink。有什么问题可以联系我哈。

    鼓励作者写出更好的技术文档,就请我喝一瓶哇哈哈哈哈哈哈哈。。你们的赞助决定我更新的速度哦!

    微信:

    支付宝:


    感谢一路支持我的人。。。。。
    
    Love me and hold me
    QQ:69673804(16年老号)
    EMAIL:itw@tom.com
    友链交换
    如果有兴趣和本博客交换友链的话,请按照下面的格式在评论区进行评论,我会尽快添加上你的链接。
    

    网站名称:KingYiFan’S Blog
    网站地址:http://blog.cnbuilder.cn
    网站描述:年少是你未醒的梦话,风华是燃烬的彼岸花。
    网站Logo/头像: [头像地址](https://blog.cnbuilder.cn/upload/2018/7/avatar20180720144536200.jpg)
    
  • 相关阅读:
    OpenACC 书上的范例代码(Jacobi 迭代),part 4
    WRF 安装备忘
    荒川网格
    位运算骚操作 Part 3
    CUDA compiler driver nvcc 散点 part 2
    稀疏矩阵 part 5
    稀疏矩阵 part 4
    稀疏矩阵 part 3
    稀疏矩阵 part 2
    稀疏矩阵 part 1
  • 原文地址:https://www.cnblogs.com/kingyifan/p/11721428.html
Copyright © 2011-2022 走看看