flink cdc table api toDataStream报错解决

版本

flink 1.14.4 flink-cdc 2.2.1

现象

使用flink cdc监听mysql表 使用tableEnv.toDataStream将Table转换为DataString时报错：

Table sink ‘xxx’ doesn’t support consuming update changes […].

原因

toDataStream函数仅支持append-only/insert-only语义，不支持update语义

解决

使用toChangelogStream