我在mysql中定义了一个推荐表,其中包含3列: user_id、item_id、rank、flink将计算一些建议并将结果插入mysql中,当用户单击某个项时,我只希望mysql存储用户最近一次单击所触发的建议。既然flink mysql连接器不支持delete,我如何做到这一点?如果需要大数据计算,这种框架在这种情况下是否常见?
发布于 2022-06-28 11:50:55
Flink的MySQL连接器确实支持删除1。您必须定义一个主键,然后它将执行更新/删除。如果不提供主键,则连接器以附加模式运行。
https://stackoverflow.com/questions/72784729
复制相似问题