toAppendStream doesn‘t support consuming update and delete changes which is produced by node XXX
在Flink sql进行测试输出， 想把 sql查询的结果Table 转为DataStream 然后进行打印当我们table.toAppendStream[Row]的时候 发现报错其实这个因为我们sql 查的那个动态表 是Mysql 这类源， 他们是可以进行update,delete,insert操作的。对于toAppendStream呢 是仅可以将追加流进行转换输出 比如kafka所以我们使用t
·
在Flink sql进行测试输出， 想把 sql查询的结果Table 转为DataStream 然后进行打印
当我们table.toAppendStream[Row]的时候 发现报错
其实这个因为我们sql 查的那个动态表 是Mysql 这类源， 他们是可以进行update,delete,insert操作的。
对于toAppendStream呢 是仅可以将追加流进行转换输出 比如kafka
所以我们使用
table.toRetractStream[Row].print() 即可
这操作呢打印结果是一个有两部分， 前面部分为boolean类型， 后面是你的select 其中 true表示insert ，false表示 update/delete
对于Table / sql 转 Stream 可以看官网也有详细的讲解
Kafka开源项目指南提供详尽教程，助开发者掌握其架构、配置和使用，实现高效数据流管理和实时处理。它高性能、可扩展，适合日志收集和实时数据处理，通过持久化保障数据安全，是企业大数据生态系统的核心。
更多推荐
2
0- 0
已为社区贡献3条内容
所有评论(0)