需求：使用 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;