问答 2024-03-28 来自:开发者社区

使用flinkcdc同步mysql至mysql的数据,只会同步一次,修改源表后目标表没有变化

我用这个代码 同步mysql的数据到另一个mysql 只会同步一次 第一次同步完成后后续源表变更目标表没有变化 flink版本是1.16.3 cdc是2.3.0 而且执行完insert后,web ui也没有任务 这是flink下lib中的jar包 尝试过更换flink或者cdc的版本,然后还会报其他乱七八糟的错误。都是没有办法解决的。尝试过直接在flink sql client中写inse...

问答 2023-07-26 来自:开发者社区

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表,没更新?

flink sql任务有三个mysql cdc 源表通过left join关联写入目标表。过了半天之后,更新源表中的记录,发现目标表没更新。这是flink SQL不支持吗,还是要做什么特殊设置,或者使用什么语法?就是更新了where条件对应的记录,另外,大表join,是如何做实时记录匹配的,应该是需要流内存拦截吧,不然怎么做到实时匹配呢?假如关联的两张表的记录一个在最开始就来了,另一个迟了很久才....

问答 2023-07-26 来自:开发者社区

请问flink mysql cdc 双流left join后再入库在目标表c没有删除呢?

"请问flink mysql cdc 双流left join后再入库mysql,insert into c select from a left join b,源表a某些数据删了,在目标表c没有删除呢?三个表都设置了主键。请问怎么解决?测试删除trans_detail的数据,在结果表里没有被删除,没有left join的话,能同步删除。INSERT INTO tr_flow_base_info_....

问答 2022-09-01 来自:开发者社区

有大佬知道这个问题吗?我把mysql 作为cdc时,select没问题,然后作为目标表

有大佬知道这个问题吗?我把mysql 作为cdc时,select没问题,然后作为目标表,写的时候报这个错

问答 2022-07-08 来自:开发者社区

大佬们,我用flink sql client进行mysql增量同步,源表新增10w,同步目标表只有3

大佬们,我用flink sql client进行mysql增量同步,源表新增10w,同步目标表只有3w,有什么配置或办法加快同步速度吗

问答 2020-05-17 来自:开发者社区

MySQL#1093-您无法在FROM子句中指定目标表'giveaways'进行更新?mysql

我试过了: UPDATE giveaways SET winner = '1' WHERE ID = (SELECT MAX(ID) FROM giveaways) 但是它给出: #1093-您不能为FROM子句中的更新指定目标表'giveaways'

问答 2020-05-08 来自:开发者社区

MySQL错误1093-无法在FROM子句中指定目标表进行更新

story_category我的数据库中有一个表,其中的条目已损坏。下一个查询返回损坏的条目: SELECT * FROM story_category WHERE category_id NOT IN ( SELECT DISTINCT category.id FROM category INNER JOIN story_category ON category_id=category.id.....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像