百岁

Results 117 comments of 百岁
trafficstars

> 添加mysql同步到redis的功能, 可以指定表的数据,按照自定义格式同步到redis中的自定义键中。 比如通常用的字典表,可以按照几个字段组成的json字符串或hash或list,同步到redis中的指定键中。 收到,理解你的需求,后期实现可以基于redis的目标端可以继承kafka的sink端,将原先写入kafka的记录改成写入到reids存储中。

能否提供提供: 1. 建表的ddl, 2. 该表的insert语句,有代表性的一条即可 另外,我测试是使用v9r1 版本,您是否测试过该版本?,docker启动命令如下: ``` shell docker run -tid --privileged -p 4321:54321 -v /root/kingbase/data_mysql:/home/kingbase/userdata/ -e ENABLE_CI=yes -e NEED_START=yes -e DB_USER=kingbase -e DB_PASSWORD=123456 -e DB_MODE=mysql --name kingbase_mysql kingbase_v009r001c002b0014_single_x86:v1...

> 晚上给您提供,主要是现在这边他们主推的还是v8r6之类的版本(v9的版本甲方这边采购感觉不稳定),导致我这边测试都测8.6 建表的ddl我晚上给您导出来,其实很简单,就是主键 int4 或者 int8 ok,等你提供了sql 脚本之后我本地搭建一个v9的环境测试一下

以上提供的SQL 你确定是 MySQL 版本的?因为依据你提供的docker启动命令中的参数`DB_MODE=mysql` ,应该是MySQL 模式,但是你提供的DDL 和Insert 脚本应该PG模式的吧?

那你使用的数据通道是 从postgresql 同步到 模式为mysql kingbase 数据吗?你提供的 DDL 是 源库postgresql 的?

> 1809040656 我没有qq ,加我微信:16660356

> 对于支持ddl变更,如不能实时同步的话,也可以按这样的场景操作。如上游mysql表增加字段,对应同步任务报错中断,然后手工在starrocks中增加字段后,再重新开启实时同步。不知道这样是否可行 你的意思,不希望通过现在的删除增量通道的过程,而是手动添加完字段之后,可以立即启动运行。 是这样吧?

> 场景描述: 将生产mysql实时同步至starrocks,先同步全量表结构及数据,再同步增量 > > 希望有的功能: 1. 全量同步后,能记录最后的binlog信息,这样方便后续配置增量同步 ==》 这个届时会尝试一下把binlog的偏移量显示在TIS的UI上 2. 增量同步中希望能增加从指定binlog位点进行同步 ==》 这个之前看flink-cdc的文档应该是支持直接设置gtid的偏移量,从指定的偏移位点开始消费 3. 如当前已配置整库同步任务,如果mysql中新建了一张表,希望能自动或手动修改配置,实现新表同步至starrocks 4. 支持mysql中的ddl变更同步,如添加字段、删除字段、修改数据类型等ddl操作 ===》 3,4两点暂时还不能支持 6. 支持建表类型转换,如starrocks不支持time类型,可以配置类型映射,比如自动建表时把time类型替换为varchar类型 ==》 您说的 `starrocks不支持time类型` ,那可否映射成datetime,date部分直接设置成1970年?您说的办法`自动建表时把time类型替换为varchar类型` 倒是也行,只是需要在flink-sql上设置一下convert语句

> ,tis侦测到ddl变更后,实时同步任务立即报错中断,然后手工介入,在下游starrocks中执行ddl变更后,再重新开启tis平台的实时同步 方案不错能够进一步细化报错规则?例如,上游表加字段,TIS侦测到ddl变更就立即报错并且终止任务执行,这是否有必要?

> 中断同步任务,报错规则,常见的兼容mysql以下几类操作就可以 > 1、建表,删表:create table xxx,drop table xxx > 2、增加字段:alter table xxx add column > 3、删除字段:alter table xxx drop column > 4、修改字段:alter table xxx change/modify column > 5、增加索引:alter table xxx...