请教下各位大佬，FlinkCDC OceanBase connector，不支持两张cdc表的表？

Flink CDC OceanBase Connector 支持两张 CDC 表的 Join 操作，您可以通过使用 Flink 的 Table API 或者 SQL API 实现。

具体实现方式取决于您使用的 Flink 版本和 API 类型。以下是基于 Flink 1.14 版本的示例代码，仅供参考：

使用 Table API 实现 Join 操作
java
Copy
// 创建 TableEnvironment
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);

// 创建 Table1 和 Table2
Table table1 = tEnv.from("cdc_table1");
Table table2 = tEnv.from("cdc_table2");

// 执行 Join 操作
Table result = table1.join(table2).where("id = id").select("id, name");

// 输出结果
DataStream dataStream = tEnv.toAppendStream(result, Row.class);
dataStream.print();
使用 SQL API 实现 Join 操作
java
Copy
// 创建 TableEnvironment
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);

// 注册 Table1 和 Table2
tEnv.executeSql("CREATE TABLE table1 (id INT, name STRING) WITH (...)");
tEnv.executeSql("CREATE TABLE table2 (id INT, age INT) WITH (...)");

// 执行 Join 操作
Table result = tEnv.sqlQuery("SELECT t1.id, t2

回答1:join 走的是fink 的双流join，你是数据丢了还是语法错误？logproxy.client.id你设置了吗，每张表都不一样，此回答整理自钉群“Flink CDC 社区”