云数据库 RDS MySQL 版数据的相关内容

返回频道云数据库 RDS MySQL 版数据

问答 2023-06-11 来自：开发者社区

Flink CDC中本地写了个mysql 的demo，项目启动的时候数据计算了一遍，后面？

Flink CDC中本地写了个mysql 的demo，项目启动的时候数据计算了一遍，后面source数据发生变化，目标表数据没有更新，这个是什么原因，哪位大佬知道吗？

问答 2023-06-11 来自：开发者社区

flinkcdc，mysql同一个主键id，同一条数据，先插入，再更新，再删除，数据没有放到？

flinkcdc，mysql同一个主键id，同一条数据，先插入，再更新，再删除，数据没有放到kafka的同一个分区，这个正常吗？sql，指定了主键没指定key，有参考的资料吗？

问答 2023-06-11 来自：开发者社区

各位大佬，flinkcdc 怎么设置只读今天之后的 mysql 数据？历史数据不读？

各位大佬，flinkcdc 怎么设置只读今天之后的 mysql 数据？历史数据不读？CREATE TABLE mysql_source (...) WITH ( 'connector' = 'mysql-cdc', 'scan.startup.mode' = 'earliest-offset', -- 从最早位点启动 'scan.startup.mode' = 'latest-offset'....

问答 2023-06-11 来自：开发者社区

flink-1.16.1 可以配合flink-sql-使用吗？我启动后，mysql插入数据，

flink-1.16.1 可以配合flink-sql-connector-mysql-cdc-2.3.0.jar 使用吗？我启动后，mysql插入数据，flinksql里看不到数据变化嘛

问答 2023-06-11 来自：开发者社区

大佬我mysql 去加载数据的时候怎么做前置处理呢？我想过滤掉一些不需要的数据？

问题1:大佬我mysql 去加载数据的时候怎么做前置处理呢？我想过滤掉一些不需要的数据？问题2:在ddl里面可以吗？我是想用某个产品id过滤这部分数据我在源表里面就不加载了。比如product_id ='1'的这部分过滤掉

问答 2023-06-11 来自：开发者社区

Flink CDC 中mysql到mysql数据实时同步，大概有100多张表，flink cdc能?

Flink CDC 中mysql到mysql数据实时同步，大概有100多张表，flink cdc能抗住嘛？

问答 2023-06-11 来自：开发者社区

Flink CDC 怎么才能同步多个表的数据呀？好像不支持正则，我按照mysql的写法写上去一个表也

Flink CDC 怎么才能同步多个表的数据呀？ postgres好像不支持正则，我按照mysql的写法写上去一个表也读不到

问答 2023-06-11 来自：开发者社区

大佬我发现Flink CDC出来的数据比我MYSQL数据要多什么情况？

大佬我发现Flink CDC出来的数据比我MYSQL数据要多什么情况？select 1234 as id, count(distinct(papers_number)) as user_num from biz_user where papers_number is not null cdc写mysql，读mysql 写mysql

问答 2023-06-11 来自：开发者社区