FlinkFlink 写入 MySQL主键冲突 默认Upsert策略

Posted 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了FlinkFlink 写入 MySQL主键冲突 默认Upsert策略相关的知识，希望对你有一定的参考价值。

文章目录

本文为博主九师兄（QQ:541711153 欢迎来探讨技术）原创文章，未经允许博主不允许转载。

1.概述

请问我有个个flinkSQL程序，这个程序的功能


然后我故意造出来 2次join的数据结果是不一样的 但是 id，是一样的，这样想让第二次join失败 报错 主键冲突 但是实际测试第二条数据自动变成了update 把2第一条数据更新了

这是什么情况?

以上是关于FlinkFlink 写入 MySQL主键冲突 默认Upsert策略的主要内容，如果未能解决你的问题，请参考以下文章

oracle大数据量写入时主键冲突，如何解决

Postgresql insert on conflict笔记

mysql实现upsert

mysql修改数据 -- 主键冲突

mysql 存储过程 若主键冲突则更新，不冲突则插入数据

FlinkFLink 写入kafka 中关于 Exactly-Once 的一些思考