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

SQL Server To Paimon Demo by Flink standalone cluster mode

需求:使用 Flink CDC 测试 SQL Server 连接 Paimon

操作:启动 Flink standalone cluster 后,接着启动 Flink SQL Client,则通过 Flink SQL Client 提交 insert & select job 到该 8081 cluster

Flink SQL Client 执行案例 - 

-- to paimonCREATE CATALOG my_catalog WITH ('type'='paimon','warehouse'='file:/tmp/paimon'
);USE CATALOG my_catalog;CREATE TABLE paimon_users (id INT PRIMARY KEY NOT ENFORCED,name VARCHAR(50)
);CREATE TEMPORARY TABLE users (id INT,name VARCHAR(50),PRIMARY KEY (id) NOT ENFORCED
) WITH ('connector' = 'sqlserver-cdc','hostname' = '','port' = '1433','username' = '','password' = '','database-name' = 'poc_db','table-name' = 'lab.users'
);SELECT * FROM users;SET 'execution.checkpointing.interval' = '5 s';INSERT INTO paimon_users SELECT id, name FROM users;SELECT * FROM paimon_users;

http://www.xdnf.cn/news/4442.html

相关文章:

  • 力扣1812题解
  • 二叉树的遍历与构造
  • 性能优化-初识(C++)
  • 国产ADS1296兼容类比代替芯片——LHE7906
  • 滑动窗口——无重复字符最长的字串
  • 分布式-基于数据库排他锁
  • 文章记单词 | 第69篇(六级)
  • windows安装micromamba
  • SimpleMindMap:一个支持AI的思维导图软件
  • 电能质量监测A级与S级的区别详解
  • LVS中的DR模式,直接路由模式
  • 大模型Agent技术全景解析:架构演进、场景适配与关键技术拆解
  • 2025ISCC练武校级赛部分题解WP
  • Flink + Kafka 数据血缘追踪与审计机制实战
  • LeetCode383_赎金信
  • Mac中Docker下载与安装
  • [学习]RTKLib详解:ppp.c与ppp_ar.c
  • 如何保证Kafka生产者的消息顺序性? (单分区内有序,需确保同一Key的消息发送到同一分区)
  • 网站网页经常 400 错误,清缓存后就好了的原因剖析
  • 【JMeter技巧】GET请求如何传递Body参数?版本兼容性详解场景需求
  • 风车 AI 翻译如何免费解决跨境电商图片翻译难题
  • 机器学习——逻辑回归ROC练习
  • Milvus 向量数据库详解与实践指南
  • OSCP - Proving Grounds - Sumo
  • powershell批处理——io校验
  • 力扣刷题Day 37:LRU 缓存(146)
  • 7系列 之 ISERDESE2
  • 准确---Typora配置Gitee图床并实现自动图片上传
  • 【上位机——MFC】序列化机制
  • 使用 pgrep 杀掉所有指定进程