flink cdc table api toDataStream报错解决
flink cdc table api toDataStream报错解决
路过君
发布于 2022-06-08 17:17:04
发布于 2022-06-08 17:17:04
版本
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
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2022-06-07，如有侵权请联系 cloudcommunity@tencent.com 删除
目录
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号