Flink CDC如何使用per job提交sql作业？

Flink CDC可以通过以下方式进行per-job的模式提交Flink SQL作业：

1. 使用Flink CLI或SQL Client。
2. 使用Flink REST API。

但是session模式一直是不推荐的，yarn 现在官网推荐的不是Application Modehttps://nightlies.apache.org/flink/flink-docs-release-1.18/docs/deployment/resource-providers/yarn/%E5%90%B4%E6%B8%85%E8%93%9D，此回答整理自钉群“Flink CDC 社区”

Flink CDC支持通过Per Job提交SQL作业。具体步骤如下：

1. 编写SQL语句，例如：

CREATE TABLE my_table (
  id INT,
  name STRING,
  age INT
) WITH (
  'connector' = 'mysql-cdc',
  'hostname' = 'localhost',
  'port' = '3306',
  'username' = 'root',
  'password' = 'password',
  'database-name' = 'test',
  'table-name' = 'my_table'
);

1. 将上述SQL语句保存为一个文件，例如create_table.sql。

2. 使用Flink的命令行工具或Web界面提交作业，并指定SQL文件的路径和名称，例如：

./bin/flink run -d -p 3306 /path/to/create_table.sql

其中，-d表示以detached模式运行作业，-p表示指定MySQL的端口号。

1. 如果需要查看作业的状态和日志，可以使用Flink的命令行工具或Web界面进行操作。