Flinkcdc 不能监控试图？怎么处理视图的 先采集原表？

对于Flink CDC监控视图数据,有以下几种方式:

直接监控基表,视图数据自动同步更新。
缺点是需要消费和处理更多基表的数据。

记录DDL操作,重建视图结构后再从基表恢复视图数据。

采集基表后,在Flink作业内部自定义实现视图逻辑。

将视图定义转化为基表insert语句采集。

如果视图逻辑简单,可以直接定期同步所有基表数据重新构建视图。

一般来说,目前Flink CDC还不支持直接监控视图变更。

需要根据业务和视图定义的复杂度,选择合适方式:

简单视图 directly monitor base tables

复杂视图 recreate view logic in Flink job

视图就是一个查询，不用想也不会去采集查询啊。视图本身存储就是一段未执行的selec语句，什么都是空的，只有像一些db的物化视图才有数据。此回答整理至钉群“Flink CDC 社区”。