Xie Yi

> I had not fix it. Here is the ideas, maybe you can refer to it com.ververica.cdc.connectors.tidb.table.utils.TableKeyRangeUtils (1)get the minKey、MaxKey of TIDB table.(via Tikv client or jdbc) (2)set delta =...

I had the same question. maybe the problem is similar to this issue：https://github.com/tikv/client-java/issues/628 tidb-cdc don't receive ChangeDataEvent from tikv store after several hours,because tikv region transfer leader. you can verify...

I had take a fix in https://github.com/ververica/flink-cdc-connectors/pull/1207 With this fix , with test, no data lost . Tidb table ```sql mysql> select count(1) from tidb_cdc_test; +----------+ | count(1) | +----------+...

@GOODBOY008 @leonardBang could you please have a look ,thanks so much~

> Hi @GOODBOY008 Actually , It can repeat without debug. The bug can be repeated **when there are change log in tidb during readSnapshotEvents**. Here is the process: Environment :...

> TM print in step 5 

> add metrcis: currentFetchEventTimeLag, currentEmitEventTimeLag, sourceIdleTime for TiKVRichParallelSourceFunction > Thanks @xieyi888 for the great work! Before this PR could be merged, could you please rebase it with latest `master` branch?...

It seems the failed CI test was not caused by this PR

I‘m looking forwared to this PR! But I have some questions It seems ams-server did not include authorization and authentication, How can we use this function on ams terminal? Do...

 Organization / 组织: youdao (有道) Region / 地区: Beijing, China Contact / 联系方式: [[email protected]](mailto:[email protected]) Usage Scenario / 使用场景: we use Amoro to build batch-and-stream-fused data pipelines.