> 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
