retraction专题

FlinkSQL中的回退更新-Retraction

公众号《大数据技术与架构》,大数据领域高级进阶 已关注 5 人赞同了该文章 前言 如果你在使用FlinkSQL时出现如下的报错: Table is not an append-only table. Use the toRetractStream() in order to handle add and retract messages. 那么你就有必要了解一下Flink中的回退更新。