程序员经验分享-hwhale

FlinkCDC第二部分-搭建Flink单机服务，ctrl就完事~

2023-11-11

Flink版本：1.16

环境：Linux CentOS 7.0、jdk1.8

基础文件：flink-1.16.2-bin-scala_2.12.tgz、flink-connector-jdbc-3.0.0-1.16.jar、flink-sql-connector-mysql-cdc-2.3.0.jar

1. 在目录/home/flink下解压flink-1.16.2-bin-scala_2.12.tgz文件

        tar -zxvf flink-1.16.2-bin-scala_2.12.tgz

2. 添加环境变量：

vim etc/profile

添加环境flink环境变量：

#FLINK_HOME

export FLINK_HOME=/home/flink-1.16.2

export PATH=$PATH:$FLINK_HOME/bin

环境变量及时生效：

source /etc/profile

3. 在目录/home/flink-1.16.2/conf下修改配置文件flink-conf.yaml：

        只需要修改一个地方

        rest.bind-address: 0.0.0.0 （默认是localhost）

4. 将jar包flink-connector-jdbc-3.0.0-1.16.jar、flink-sql-connector-mysql-cdc-2.3.0.jar放到 flinkcdc安装路径lib文件夹下

5. 到目录/home/flink-1.16.2/bin下运行：

开启Flink服务：

[root@localhost bin]#  ./start-cluster.sh

出现下图即启动成功：

启动FinkSQL：

[root@localhost bin]# ./sql-client.sh

出现：小松鼠图案即开启成功

 停止服务：

[root@localhost bin]#  ./stop-cluster.sh

出现下图即停止成功：

 

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

运行环境

flink

大数据

FlinkCDC第二部分-搭建Flink单机服务，ctrl就完事~ 的相关文章

  • 多重背包问题 可行性问题O(V N) 算法

    原文地址 多重背包问题 可行性问题O V N 算法 问题 有n种不同大小的数字ai 每种各mi个 判断是是否可以从这些数字中选出若干个使他们的和为k 算法一 include

  • 随机信号功率谱密度函数理论、估计方法及MATLAB代码

    文章的内容整理自网络 仅Matlab代码部分进行了部分修正 具体而言 理论部分来自 现代通信原理2 5 确定信号的能量谱密度 功率谱密度与自相关函数 估计和代码部分来自 随机信号功率谱密度估计 PS1 推荐使用周期图法进行功率密度谱估计 P

随机推荐

  • 你业余时间在做什么？

    author skate time 2010 04 20 哈佛大学凌晨4点半的景象 在网上看到这篇文章 觉得很有感触 或许这再一次印证任何人每一次的成功背后都有不为人知的付出和汗水 人的时间和精力都是有限的 所以 要利用时间抓紧学习 而不是

  • 面试问到AOP就该这样回答

    前言 相信各位小伙伴在准备面试的时候 AOP都是无法绕过的一个点 经常能看到动态代理 JDK动态代理 CGLIB动态代理这样的字眼 其实动态代理是代理模式的一种 代理模式有静态代理 强制代理 动态代理 所以在认识AOP之前需要了解代理模式

  • 如何低代码开发区块链应用

    区块链技术近年来在国内迅速发展 并在众多领域开展探索并有不少应用落地 作为一门新型技术 区块链技术在助力企业效率提升的同时 在人力成本 联盟链兼容等方面仍然需要释放更多可能性 如何降低区块链的开发成本 使其更高效便捷地应用到产业当中 成为提

  • 为什么区块链是互联网的100倍？

    区块链的本质究竟是什么 如果区块链只是一个简单的分布式账本 凭什么在全世界的所有国家 商业领域掀起一浪又一浪的轩然大波 而如此多的精英人士不顾一切的争相入场 假设比特币是第一张多米诺骨牌 区块链究竟翻倒了哪些牌 洗牌的底层逻辑又是什么 未来

  • JDBC连接断开，autoReconnect=true失效解决方案：做一个合格的回头客！

    以mysql数据库为例 为避免无效连接长时间占用资源 一般超过一定时间不操作就会断开连接 利用 show global variables like wait timeout 可查看等待时间 网络普遍的说法是使用autoReconnect

  • vscode远程连接服务器+上下传文件

    VSCode远程服务器记录 目录 VSCode远程服务器记录 前言 一 连接远程服务器 二 上传文件到服务器 三 从服务器上下载文件到本地 四 删除没用的远程服务器 前言 确保本地vscode中装了remote ssh和sftp的插件 这里

  • 区块链基础学习1

    1 区块链 Blockchain 区块链技术是指通过去中心化和去信任的方式集体维护一个可靠数据库的技术方案 2 点对点 P2P 通过允许单个结点与其他结点直接交互 无需通过中介机构 从而实现整个系统像有组织的集体一样运作的系统 3 去中心化

  • POC模拟攻击利器 —— Nuclei入门（一）

    引入Nuclei的缘由 使用dependency check 发现的问题 需要研发人员修复 研发人员要求复现问题 这个的确有难度不仅仅要了解cve 相关bug的具体含义 还要模拟攻击 对于测试人员显然要求过高 凭借自己多年的各种测试工具调研

  • uniapp滚动加载 下拉刷新

    前言 在日常开发中 滚动加载和下拉刷新是非常常见的功能 页面数据过多时 需要滚动加载优化性能 本篇技术分享博客将介绍如何在uniapp中实现滚动加载和下拉刷新 预览 滚动加载 下拉刷新 一 滚动加载 滚动加载指的是当用户滑动页面到底部时 自

  • MYSQL--基础--09--备份还原常用命令

    MYSQL 基础 09 备份还原常用命令 1 数据库信息 数据库地址 127 0 0 1 数据库用户名 root 数据库密码 1234 数据库名称 test1 数据库名称 test2 数据库名称 test3 mysqldump目录 usr

  • syntax error near unexpected token in 解决方案

    目录 一 引言 二 问题解决 三 总结 一 引言 近来在使用 shell 脚本时 从服务器上把脚本文件拿下来 本地修改完之后上传至服务器 运行时出现了如下的错误信息 最终排查之后 发现是系统兼容性问题 现就解决方案做出说明 二 问题解决 首

  • Github建个人静态网页

    如何将个人静态网页搭建在Github上 前言 最近有不少人问我如何将个人网站搭建在Github上 由于不能一一回复 所以我就将过程写成一篇小教程 发在csdn上面 仅供参考 17岁以下的小朋友不需要在家长的陪同下阅读本文 使用工具 Goog

  • 如何看懂别人的项目代码

    1 先运行别人的demo 然后再去看文档 2 运行调试 新的 1 了解项目 要知道这个项目是用来干嘛的 有什么样的功能 2 获取源代码 3 运行 4 一定要亲自运行一下 玩一玩 看看都有什么功能 都能完成什么事情 要想对项目源码了解 首先必

  • 基于python的种子搜索网站，你懂得！

    该项目是基于python的web类库django开发的一套web网站 给师弟做的毕业设计 本人的研究方向是一项关于搜索的研究项目 在该项目中 笔者开发了一个简单版的搜索网站 实现了对数据库数据的检索和更新 通过开发该项目 笔者学习和巩固了p

  • css自适应布局，缩放保持图片比例

    场景一 适合商品类展示型布局 后台的数据呈现列表数据返回 窗口宽度变化 图片比例不变 假设我们的图片宽高固定比例16 9 效果图满屏 效果图缩放时 移动端 直接看代码 里面会注释详细说明 div class parentBox div cl

  • Matter Project 入门 – Matter开发环境设置

    如果您尚未在计算机上本地运行 Ubuntu 您将需要一个替代方案来开发 Matter 设备 你需要什么 用于构建 Matter 终端设备固件的 Linux 环境 我们将为这个项目使用 Ubuntu 21 10 服务器 但任何 Ubuntu

  • 软考之运筹学计算-车床问题

    软考之运筹学计算 车床问题 一 真题示例 二 题意分析 三 解答 一 真题示例 某车间需要用一台车床和一台铣床加工A B C D四个零件 每个零件都需要先用车床加工 再用铣床加工 车床与铣床加工每个零件所需的工时 包括加工前的准备时间以及加

  • AndroidStudio新建项目报错build failed

    AndroidStudio新建项目报错build failed 报错信息 org gradle initialization ReportedException org gradle internal exceptions Location

  • VC6提示番茄助手过期

    VC6提示番茄助手过期 无法打开 在控制面板中卸载即可

  • FlinkCDC第二部分-搭建Flink单机服务，ctrl就完事~

    Flink版本 1 16 环境 Linux CentOS 7 0 jdk1 8 基础文件 flink 1 16 2 bin scala 2 12 tgz flink connector jdbc 3 0 0 1 16 jar flink s

热门标签