Flink CDC中SQLServer多库同名表写入到一张sink表中，有什么思路吗？

针对你的问题，我提出以下两个方案：

1. 使用Flink SQL中的视图联合技术。你可以在Flink SQL中定义多个视图，每个视图代表一个源数据库中的表。然后，你可以使用UNION ALL操作将这些视图联合起来，形成一个新的结果集。最后，你可以把这个结果集插入到目标数据库的表中。

CREATE VIEW view1 AS ...
CREATE VIEW view2 AS ...
INSERT INTO sink_table SELECT * FROM view1 UNION ALL SELECT * FROM view2;

1. 使用Flink的MultipleInputs技术。你可以在Flink程序中定义多个输入源，每个输入源代表一个源数据库中的表。然后，你可以使用DataStream.union操作将这些输入源联合起来，形成一个新的数据流。最后，你可以把这个数据流插入到目标数据库的表中。

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource<Row> source1 = ...;
DataStreamSource<Row> source2 = ...;
DataStream<Row> unionedStream = source1.union(source2);
unionedStream.addSink(...);
env.execute();

这两种方案都可以实现将多张源数据库的表写入到一张目标数据库的表中。其中，第一种方案更加灵活，因为它可以直接在Flink SQL中完成所有操作；第二种方案则更加底层，它可以让你完全控制数据流的处理过程。

等3.0 有整库同步，此回答整理自钉群“Flink CDC 社区”