zaorangyang
zaorangyang
发送模式设置为concurrent时,logQueue使用的是go提供的非缓冲内存队列。当从logQueue中拿出数据并且还未完成发送,此时logkit被kill掉,这样会丢失一部分数据
## What type of PR is this: - [ ] BugFix - [ ] Feature - [x] Enhancement - [ ] Refactor - [ ] UT - [ ] Doc...
## What type of PR is this: - [ ] BugFix - [ ] Feature - [ ] Enhancement - [x] Refactor - [ ] UT - [ ] Doc...
## What type of PR is this: - [x] BugFix - [ ] Feature - [ ] Enhancement - [ ] Refactor - [ ] UT - [ ] Doc...
## Enhancement support set tablet max versions dynamically
我的集群是3个shard,每个shard3个replica的架构,但是当一个flink job finish之后,check ck的表的数据,发现数据条数比插入的数据数目少,过一段时间后,ck表的数据数量才慢慢达到插入的数据量。为什么会出现这种现象?
I'll start by describing my use case. I use ExportColumnFamily to export data from one database, let's call it DB1, as a backup. Then, I create a completely new and...