当前位置: 首页 > news >正文

centos7的flink安装过程

安装步骤

  1. 下载flink的tar.gz包
  2. 修改flink的conf配置
  3. 下载需要的lib包

具体代码(以flink1.15为例)

# 下载flink的tar.gz包
wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-bin-scala_2.12.tgz
tar -zxvf flink-1.15.4-bin-scala_2.12.tgz# 修改flink的conf配置
vim /root/flink1.15/flink-1.15.4/conf/flink-conf.yaml 
# 将所有的bind后面的都改成0.0.0.0
jobmanager.bind-host: 0.0.0.0
taskmanager.bind-host: 0.0.0.0
rest.bind-address: 0.0.0.0# 下载需要的jar包,我这边是需要mysql CDC到mysql
wget https://repo.maven.apache.org/maven2/org/apache/flink/flink-connector-jdbc/1.15.4/flink-connector-jdbc-1.15.4.jar
wget https://repo.maven.apache.org/maven2/mysql/mysql-connector-java/5.1.9/mysql-connector-java-5.1.9.jar
wget https://repo1.maven.org/maven2/com/ververica/flink-sql-connector-mysql-cdc/2.0.2/flink-sql-connector-mysql-cdc-2.0.2.jar
# 下载的jar包放到/root/flink1.15/flink-1.15.4/lib就好,需要重启flink# 启动flink
cd /root/flink1.15/flink-1.15.4/
./start-cluster.sh 
# 关闭flink
./stop-cluster.sh 
# 运行flink-sql(需要在flink启动的状态下)
./sql-client.sh -f m2dwm.sql
# 访问flink控制台
http://IP:8081/
http://www.lryc.cn/news/129855.html

相关文章:

  • 商城-学习整理-高级-性能压测缓存问题(十一)
  • PHP 三元 !empty 而不是评估为真或假 可用isset()
  • 星火大模型 VS FuncGPT(慧函数), 谁更胜一筹?
  • 使用 Python 获取 Redis 数据库中的所有键
  • C的进阶C++学习方向
  • 【仿写框架之仿写Tomact】二、初始化阶段加载项目中所有servlet类对象
  • Linux实用运维脚本分享
  • JMeter 特殊组件-逻辑控制器与BeanShell PreProcessor 使用示例
  • 时序预测 | MATLAB实现SA-ELM模拟退火算法优化极限学习机时间序列预测
  • Ubuntu 连接海康智能相机步骤(亲测,成功读码)
  • sass笔记
  • C/C++中volatile关键字详解
  • Linux:shell脚本:基础使用(4)《正则表达式-grep工具》
  • 如何建立单元测试
  • typeScript 接口和类
  • 这项与越来越多企业有关的行业标准,网易云信深度参与制定!
  • C语言,malloc使用规范
  • 广度优先遍历与最短路径(Java 实例代码源码包下载)
  • 南大通用数据库(Gbase 8s) 创建UDR外部函数
  • 步入React正殿 - State进阶
  • 【QT+ffmpeg】QT+ffmpeg 环境搭建
  • 责任链模式解决多个ifelse问题
  • Lnton羚通关于PyTorch的保存和加载模型基础知识
  • python+django+mysql项目实践四(信息修改+用户登陆)
  • sCrypt编程马拉松于8月13日在复旦大学成功举办
  • Selenium手动和自动两种方式启动Chrome驱动
  • 《PostgreSQL 开发指南》第32篇 物化视图
  • 【RocketMQ】快速入门
  • AB跳转轮询:让你的独立站收款智能化
  • 所有用户都能使用sudo吗