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

请教大佬们,请问用flink sink数据到mysql有事务控制吗?如果在一个checkpoint时

请教大佬们,请问用flink sink数据到mysql有事务控制吗?如果在一个checkpoint时间范围内处理了1000条数据,但是checkPoint失败了,那么这个1000条数据是没有写入mysql呢?还是写入了mysql通过事务进行回滚?还是写入后的回滚不了?

文章 2022-07-26 来自:开发者社区

『Mysql』orderby时把指定的数据分组再排序,将指定的分组数据排在前面/后面

背景,由于项目中遇到这么一个需求:在群成员group_member表中,有成员类型member_type1:微信好友2:企业好友3:非好友现在有个需求是:需要对这些数据根据进群时间做倒序排序,非好友放在最下面,但内部也也是一样根据进群时间做倒序排序问题解决SELECT * FROM group_member ORDER BY member_type=3, join_time DESC类似方案的.....

『Mysql』orderby时把指定的数据分组再排序,将指定的分组数据排在前面/后面
问答 2022-07-26 来自:开发者社区

请问使用DataWorks的数据集成功能,数据来源选RDS,数据去向不能选择RDS?

请问使用DataWorks的数据集成功能,数据来源选RDS,数据去向不能选择RDS?

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

请问一下,使用数据集成从postgreSQL导数据到Mysql数据库,有部分数据的字段中出现emoj

请问一下,使用数据集成从postgreSQL导数据到Mysql数据库,有部分数据的字段中出现emoji表情符导致数据导入失败,但是目标MySql表格是使用utf8mb4编码的,还是会出现报错信息,请问一下这要如何解决

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

我想问一下,我flink作业是以upsert-kafka的方式写入数据的,但是我在mysql里面去更

我想问一下,我flink作业是以upsert-kafka的方式写入数据的,但是我在mysql里面去更新了一条数据,发现在kafka出现了两条数据,一条value有值,一条没有值这是什么原因,哪位大佬可以解释一下吗

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

请问使用mysql-cdc作为source,如果做到数据有序性的?如果我下游sink的并行度比sou

请问使用mysql-cdc作为source,如果做到数据有序性的?如果我下游sink的并行度比source高能行吗

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

请问为什么我进行mysql数据update时,kafka中采集到的是先删除原纪录(op d)再新增新

请问为什么我进行mysql数据update时,kafka中采集到的是先删除原纪录(op d)再新增新纪录(op c),而不是新增新纪录(op u)。

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

请问一下大佬,flink 如何做到 mysql 数据库与elastic search的数据实时同步

请问一下大佬,flink 如何做到 mysql 数据库与elastic search的数据实时同步?

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

请问一下,mysql-cdc全量阶段的双流join关联表数据迟到问题怎么解决的?

请问一下,mysql-cdc全量阶段的双流join关联表数据迟到问题怎么解决的?

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

咨询个问题,我通过git上的demo读取mysql的数据,但是一直报错,我项目中是有这个包的。。怎么

咨询个问题,我通过git上的demo读取mysql的数据,但是一直报错,我项目中是有这个包的。。怎么解决?

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