问题一:在Flink指定holo的binlog的offset也属于全量消费?
在Flink指定holo的binlog的offset也属于全量消费?
参考答案:
是的,指定holo的binlog的offset也被认为是全量消费。在holo binlog的两种消费模式中,一种是全量消费,另一种是从指定的binlog offset开始的增量消费。如果指定了binlog的offset,那么就会从那个位置开始消费binlog,直到最新的binlog。这种情况下,虽然不是消费所有的binlog,但是由于是从某个偏移量开始的,所以仍然被认为是全量消费的一种方式。
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610225
问题二:Flink的holo中int2 怎么映射?
Flink的holo中int2 怎么映射?我从mysql直接cast同步过去 然后有个int2 类型 然后我想拿这个表的binlog 但是字段类型是int2 ,只能用jdbc模式么?
参考答案:
关于字段类型映射,可以看一下这个
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610223
问题三:Flink在holo中创建好小写的表了,怎么把大写映射成小写呢?ctas SQL需要怎么写?
Flink在holo中创建好小写的表了,怎么把大写映射成小写呢?ctas SQL需要怎么写?
参考答案:
CREATE TABLE IF NOT EXISTS 对应的catalog名称
.xxx
.表名
AS TABLE 源表的catalog
.数据库名称
.表名
;
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610221
问题四:当Flink同步到holo时,有没有什么方式,holo中的表字段可以统一成小写?
我们业务系统有好多个rds库,库里的表字段大小写不一。如果业务库的表字段是大写,用CTAS方式同步到holo后,字段名称也是大写,想请问下,当Flink同步到holo时,有没有什么方式,holo中的表字段可以统一成小写?
参考答案:
目前ctas不支持将holo的表转成小写
两个方法
第一,mysql重新创建或改名
第二,在holo中先创建好小写的表
关于本问题的更多回答可点击进行查看:
https://developer.aliyun.com/ask/610220
问题五:当flink任务的并行度小于shard的时候,是轮询的吗?
我咨询下flink消费hologres的binlog逻辑,他是怎么消费不同shard上的binlog的,当flink任务的并行度小于shard的时候,是轮询的吗?
参考答案:
您好,麻烦先看一下这篇文档呢
关于本问题的更多回答可点击进行查看: