当前位置: 首页 > 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;

相关文章:

  • 多线服务器具有什么优势
  • 【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教程
  • 重庆荣昌区委区政府再设“答谢宴”,邀请800余名志愿者机关食堂用餐
  • 上海“电子支付费率成本为0”背后:金融服务不仅“快”和“省”,更有“稳”和“准”
  • 专访|李沁云:精神分析不会告诉你“应该怎么做”,但是……
  • 李云泽:支持小微企业、民企融资一揽子政策将从增供给、降成本、提效率、优环境4个方面发力
  • 德国新一届联邦政府宣誓就职
  • 山东滕州市醉驾交通事故肇事人员已被刑拘