安装配置Flink

安装配置Flink

1.上传安装包到Linux

2.解压到指定路径

tar -zxf ./flink-1.14.0-bin-scala_2.12.tgz  /usr/local/src/

3.修改环境变量

vi ~/.bashrc

#往最后加入
export FLINK_HOME= /usr/local/src/flink-1.14.0/
export PATH=$PATH:$FLINK_HOME/bin

#激活环境变量
source ~/.bashrc

4.启动Flink

start-cluster.sh

5.验证

#jps命令会显示两个Flink的进程
[root@master ~]# jps
71736 TaskManagerRunner
71453 StandaloneSessionClusterEntrypoint
71900 Jps

#能够正常进入Flink的sql客户端
[root@master ~]# sql-client.sh
Command history file path: /root/.flink-sql-history

                                   ▒▓██▓██▒
                               ▓████▒▒█▓▒▓███▓▒
                            ▓███▓░░        ▒▒▒▓██▒  ▒
                          ░██▒   ▒▒▓▓█▓▓▒░      ▒████
                          ██▒         ░▒▓███▒    ▒█▒█▒
                            ░▓█            ███   ▓░▒██
                              ▓█       ▒▒▒▒▒▓██▓░▒░▓▓█
                            █░ █   ▒▒░       ███▓▓█ ▒█▒▒▒
                            ████░   ▒▓█▓      ██▒▒▒ ▓███▒
                         ░▒█▓▓██       ▓█▒    ▓█▒▓██▓ ░█░
                   ▓░▒▓████▒ ██         ▒█    █▓░▒█▒░▒█▒
                  ███▓░██▓  ▓█           █   █▓ ▒▓█▓▓█▒
                ░██▓  ░█░            █  █▒ ▒█████▓▒ ██▓░▒
               ███░ ░ █░          ▓ ░█ █████▒░░    ░█░▓  ▓░
              ██▓█ ▒▒▓▒          ▓███████▓░       ▒█▒ ▒▓ ▓██▓
           ▒██▓ ▓█ █▓█       ░▒█████▓▓▒░         ██▒▒  █ ▒  ▓█▒
           ▓█▓  ▓█ ██▓ ░▓▓▓▓▓▓▓▒              ▒██▓           ░█▒
           ▓█    █ ▓███▓▒░              ░▓▓▓███▓          ░▒░ ▓█
           ██▓    ██▒    ░▒▓▓███▓▓▓▓▓██████▓▒            ▓███  █
          ▓███▒ ███   ░▓▓▒░░   ░▓████▓░                  ░▒▓▒  █▓
          █▓▒▒▓▓██  ░▒▒░░░▒▒▒▒▓██▓░                            █▓
          ██ ▓░▒█   ▓▓▓▓▒░░  ▒█▓       ▒▓▓██▓    ▓▒          ▒▒▓
          ▓█▓ ▓▒█  █▓░  ░▒▓▓██▒            ░▓█▒   ▒▒▒░▒▒▓█████▒
           ██░ ▓█▒█▒  ▒▓▓▒  ▓█                █░      ░░░░   ░█▒
           ▓█   ▒█▓   ░     █░                ▒█              █▓
            █▓   ██         █░                 ▓▓        ▒█▓▓▓▒█░
             █▓ ░▓██░       ▓▒                  ▓█▓▒░░░▒▓█░    ▒█
              ██   ▓█▓░      ▒                    ░▒█▒██▒      ▓▓
               ▓█▒   ▒█▓▒░                         ▒▒ █▒█▓▒▒░░▒██
                ░██▒    ▒▓▓▒                     ▓██▓▒█▒ ░▓▓▓▓▒█▓
                  ░▓██▒                          ▓░  ▒█▓█  ░░▒▒▒
                      ▒▓▓▓▓▓▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒▒░░▓▓  ▓░▒█░

    ______ _ _       _       _____  ____  _         _____ _ _            _  BETA
   |  ____| (_)     | |     / ____|/ __ \| |       / ____| (_)          | |
   | |__  | |_ _ __ | | __ | (___ | |  | | |      | |    | |_  ___ _ __ | |_
   |  __| | | | '_ \| |/ /  \___ \| |  | | |      | |    | | |/ _ \ '_ \| __|
   | |    | | | | | |   <   ____) | |__| | |____  | |____| | |  __/ | | | |_
   |_|    |_|_|_| |_|_|\_\ |_____/ \___\_\______|  \_____|_|_|\___|_| |_|\__|

        Welcome! Enter 'HELP;' to list all available commands. 'QUIT;' to exit.


Flink SQL>

6.退出sql-client

quit;
#或者exitl;
#或者CRTL D快捷键

或者exit

7.停止Flink

stop-cluster.sh

相关推荐

  1. 安装配置Flink

    2024-01-10 16:14:02       37 阅读
  2. Flink SQL CDC 配置文档

    2024-01-10 16:14:02       24 阅读

最近更新

  1. TCP协议是安全的吗?

    2024-01-10 16:14:02       18 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2024-01-10 16:14:02       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2024-01-10 16:14:02       18 阅读
  4. 通过文章id递归查询所有评论(xml)

    2024-01-10 16:14:02       20 阅读

热门阅读

  1. 脚本语言 汇总-正则表达式regexp

    2024-01-10 16:14:02       31 阅读
  2. 【算法笔记】动态规划专题

    2024-01-10 16:14:02       27 阅读
  3. ubuntu 22.04 安装r-base时缺少r-recommended

    2024-01-10 16:14:02       27 阅读
  4. 力扣103. 二叉树的锯齿形层序遍历

    2024-01-10 16:14:02       39 阅读
  5. Istio 专栏目录

    2024-01-10 16:14:02       35 阅读
  6. Python的进制转换

    2024-01-10 16:14:02       35 阅读
  7. SkyWalking相关问题及答案(2024)

    2024-01-10 16:14:02       45 阅读
  8. PCL 点云八叉树射线相交

    2024-01-10 16:14:02       39 阅读
  9. 阶乘数码#洛谷

    2024-01-10 16:14:02       63 阅读
  10. 运维工程师的困境和解困之道

    2024-01-10 16:14:02       39 阅读
  11. 八股文 c++ 多态

    2024-01-10 16:14:02       28 阅读
  12. kotlin的抽象类和抽象方法

    2024-01-10 16:14:02       33 阅读
  13. WinForm 中Label自动换行 解决方法 Label自动换行

    2024-01-10 16:14:02       36 阅读
  14. 【数组】力扣704二分查找

    2024-01-10 16:14:02       40 阅读
  15. QT 简单连接WIFI模块

    2024-01-10 16:14:02       38 阅读