好的，明白了~，谢谢解答 Leonard Xu <xbjt...@gmail.com> 于2022年8月9日周二 00:12写道：
> > > > 2022年8月8日 下午3:34，林影 <brucekel...@gmail.com> 写道： > > > > 先上链接， Versioned Table > > < > https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/table/concepts/versioned_tables/ > > > > 从文档描述中可知，以Upsert-Kafka作为Source，以debezium或canal作为format时，可被认为是Versioned > > Table Source。 > > > > 1. 那么flink cdc所提供的connector下，是否也可以被认定为一种Versioned Table Source? > 可以，cdc 流上定义了 pk 和 watermark就可以作为 versioned table > > > > 2. Versioned Table 在转化成DataStream时，转化后是否必定是一个restract stream？ > 是的，所有cdc流（即changelog流）从SQL API转到Datastream时都是一个retractStream > > > 3. 是否所有的Versioned Table，都可以发送往带有撤销能力的sink（如MySQL/ES/Hudi等等）？ > > > 是的，只要sink支持回撤（retract），那么sink就支持消费changelog流 > > > 祝好， > Leonard > >
