问答 2023-11-16 来自:开发者社区

用flink cdc同步rds上的mysql数据到kafka里,请问这是什么情况?

用flink cdc同步rds上的mysql数据到kafka里,但是每次update的时候会被拆成一个create和一个delete事件。请问这是什么情况,我如果需要update时输出update事件该怎么处理?

问答 2023-11-16 来自:开发者社区

在a集群的flinkcdc去抓取部署在b集群的mysql数据变更么?

在a集群的flinkcdc去抓取部署在b集群的mysql数据变更么,b集群的mysql是部署在docker上的?

问答 2023-11-16 来自:开发者社区

cdc2.30 flink1.17,也一直抽取不到mysql的数据?

cdc2.30 flink1.17,也一直抽取不到mysql的数据?

文章 2023-11-16 来自:开发者社区

如何给MySQL 数据瘦身

目前我们《黄金国度》的大陆区经过10几次合区,DB已经达到了10G左右,分析了一下除了游戏数据本身外,还有因为采用innodb数据表引擎产生的ib_logfile0,ibdata1,为了给DB瘦身,提供了以下方案:把整个游戏数据用mysqldump出来,然后再source进新的数据库,在执行过程中,发现把整个库dump出来数据量过大,那个文件达到了3G多,于是对于大数据量的表进行分表dump,接....

文章 2023-11-16 来自:开发者社区

MySQL数据维护和灾难恢复

作为一名DBA(我目前还不是,呵呵),最重要的工作内容之一是保证数据表能安全、稳定、高速使用。因此,需要定期维护你的数据表。以下 SQL 语句就很有用:CHECK TABLE 或 REPAIR TABLE,检查或维护 MyISAM 表OPTIMIZE TABLE,优化 MyISAM 表ANALYZE TABLE,分析 MyISAM 表当然了,上面这些命令起始都可以通过工具 myisamchk 来....

文章 2023-11-16 来自:开发者社区

MYSQL 不允许在子查询的同时删除原表数据的解决方法 specify target table

MySql报错: You can't specify target table 'table namemysql中不能这么用. (等待mysql升级吧)错误提示就是说.不能先select出同一表中的某些值.再update这个表(在同一语句中) 替换方案: create table tmp as select min(id) as col1 from blur_article group by t....

问答 2023-11-15 来自:开发者社区

Flink的mysql cdc指定时间戳读取读不到数据,任务自动重启之后,新数据也读不到。怎么解决?

Flink的mysql cdc指定时间戳读取读不到数据,任务自动重启之后,新数据也读不到。怎么解决?

文章 2023-11-15 来自:开发者社区

Docker-compose封装mysql和redis并初始化数据

封装mysql目录结构./ ├── docker-compose.yml └── mysql ├── dockerfile ├── init │ └── test.sql └── mysqld.cnfdocker-compose.ymlversion: '3' services: mysql: image: mysql:1 containe...

Docker-compose封装mysql和redis并初始化数据
问答 2023-11-15 来自:开发者社区

flinkcdc全量读取mysql表中数据阶段,是直接通过jdbc读取的么?

flinkcdc全量读取mysql表中数据阶段,是直接通过jdbc读取的么?

问答 2023-11-15 来自:开发者社区

Flink CDC有测试过mysql-cdc的吞吐率么? 单线程每秒大概能获取多少的mysql数据?

Flink CDC有测试过mysql-cdc的吞吐率么? 单线程每秒大概能获取多少的mysql数据?主要就是看增加薄荷额吞吐量吧

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