Flink CDC中upsert模式10并行度写入10亿条记录，要花费很长时间，怎么加速？
Flink CDC中upsert模式10并行度写入10亿条记录，要花费很长时间，怎么加速？
大佬们，Flink CDC中sink表不支持upsert语法怎么处理？pg9.4版本不支持
大佬们，Flink CDC中sink表不支持upsert语法怎么处理？pg9.4版本不支持
问下大佬们就是flink upsert kafka sink 删除数据的时候是只能收到null值吗？
问下大佬们就是flink upsert kafka sink 删除数据的时候是只能收到null值吗，那这种的话我这边如何判断是删除了哪条数据呢？
flink source impala sink hudi的cow+upsert任务一直在反复的报错
flink source impala sink hudi的cow+upsert任务一直在反复的报这几个错误，是不是集群资源（内存和磁盘）的不足导致的？我6亿的数据量JM给了8G,TM给了10G.下图分别是JM和TM的日志
你好，现在flink cdc 在增量阶段可以实现upsert到iceberg（hive）吗 ？我用f
你好，现在flink cdc 在增量阶段可以实现upsert到iceberg（hive）吗 ？我用flink sql upsert没起作用，还是append进去了
当我使用flink cdc+ iceberg+hive同步数据，启用upsert时，提交sql jo
当我使用flink cdc+ iceberg+hive同步数据，启用upsert时，提交sql job报以下错误提示Equality field columns shouldn't be empty 已经设置了主键，使用了iceberg 的v2，请问是要在哪里设置一下吗
flink 1.11 upsert结果出错
各位大佬好，请教一个问题flink从Kafka读数，写入mysql，对mysql结果根据主键进行数据更新，看官网是支持“on DUPLICATE”的，但是在执行中报错是这个导致的语法问题。完整代码如下，是在linux下，直接python *.py执行的。请问下这个是不支持吗，还是怎么写呢！ from...
flink sql upsert模式写入mysql，es等key一定是groupby之后所有字段吗？
flink sql upsert模式写入mysql，es等key一定是groupby之后所有字段吗？ 举个例子比如我想要 insert into mysql_sink select ID， amoun...
flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert
"请问使用mysql数据库时，使用flinksql，已经设置主键的情况下，相同主键的记录没有更新，而是越来越多， 是目前不支持还是我使用的方法不对呢？ 版本：flink 1.11.1 关键的2个sql如下 create table open_and_close_terminal_minute_1 (...
哪位指点下，flink写tidb，模式是upsert,过一阵就会出现挤压，重启之后又可以追回来，能从
哪位指点下，flink写tidb，模式是upsert,过一阵就会出现挤压，重启之后又可以追回来，能从哪方面排查呢,现在是一个topic 一个partion,主要为了保证有序，下游只能起一个并发，最开始或者重启处理很快，但是过几天就突然间出现挤压，消费不过来。
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
