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

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.dtcms.com/a/175709.html

相关文章:

  • 多线服务器具有什么优势
  • 【Science Advances】普林斯顿大学利用非相干光打造可重构纳米光子神经网络
  • Easy云盘总结篇-文件分享
  • vue3的新特性
  • Frida使用java.lang.reflect.Array类打印Java反射数组
  • Mkdocs页面如何嵌入PDF
  • 【Prometheus】业务指标与基础指标的标签来源差异及设计解析(扩展版)
  • 【Prometheus】深入解析 Prometheus 特殊标签 `__param_<name>`:动态抓取参数的艺术
  • var、let、const的区别
  • WPF MVVM入门系列教程(六、ViewModel案例演示)
  • 华为设备链路聚合实验:网络工程实战指南
  • Notepad++中XML格式化插件介绍
  • GPT与LLaMA:两大语言模型架构的深度解析与对比
  • console-chat-gpt开源程序是用于 AI Chat API 的 Python CLI
  • Android学习总结之Binder篇
  • Linux 下MySql主从数据库的环境搭建
  • RDK X5 交叉编译OSS\QT\opencv\openssl
  • 【Rust模块管理】Rust包、crate与模块管理
  • 深入探讨C++日志模块设计与实现
  • 华为昇腾910B通过vllm部署InternVL3-8B教程
  • 01 一文了解大数据存储框架:数据库、数据仓库、数据集市、数据网格、数据湖、数据湖仓
  • 设计一个分布式系统:要求全局消息顺序,如何使用Kafka实现?
  • 【面板数据】公开整理-各省刑事案件统计数据集(2011-2023年)
  • 锁相环HMC830的调试
  • taro的学习记录
  • MCP 入门指南
  • 2025软考【系统架构设计师】:两周极限冲刺攻略(附知识点解析+答题技巧)
  • mac 使用 Docker 安装向量数据库Milvus独立版的保姆级别教程
  • 固件测试:mac串口工具推荐
  • 【Pandas】pandas DataFrame expanding