flink-cdc 增量同步SQL server数据

flink-cdc 增量同步SQL server数据库表数据，关联信息怎么传？
业务表A存了ID，维度表B存了Name

-- flink sql
CREATE TABLE IF NOT EXISTS A_src(
id bigint,
...
BID int
) ; 
CREATE TABLE IF NOT EXISTS B_src(
id int,
Name varchar(50)
); 
CREATE TABLE IF NOT EXISTS C_sink(
id bigint ,
...
BID bigint,
BName varchar(50)
);

insert into C_sink(id,.....,BID,BName) 
select a.ID,...,a.BID,b.Name from A_src a
left join B_src on a.ID=b.B.ID

A新增一条数据，目标表同步成功，新增了一条记录，但是维度表B的Name信息，并没有同步到目标表，为null

  • 如果你在使用Apache Flink增量同步SQL Server数据库表数据，可能会遇到相关信息没有传输的情况。这可能是因为 Apache Flink 只同步它明确配置要同步的数据。在您的示例中，维度表 B 中的名称信息听起来好像没有同步，因为它不是 Flink 配置为传输的数据的一部分。
  • 为了解决这个问题，需要重新配置 Flink，使其同步的数据中包含维度表 B 的名称信息。这可以通过更新 Flink 配置以将维度表 B 中的名称字段包含在 Flink 应同步的字段列表中来完成。
  • 一旦你更新了你的 Flink 配置，你可以运行一个全量同步来确保所有的数据都被正确同步，包括来自维度表 B 的名称信息。你可能还想设置 Flink 执行定期同步任务以确保您的数据保持最新和准确。
  • 值得注意的是，使用 Apache Flink 进行数据同步可能很复杂，可能需要一些 SQL 和数据库管理方面的知识。如果您不熟悉这些主题，最好寻求合格的专业人员的帮助，他们可以帮助您配置 Flink 并确保您的数据正确同步。