tikv-java

为提高效率,请提供以下信息,问题描述清晰能够更快得到解决:
【 TiDB 使用环境】

【概述】 场景 + 问题概述
调试flink tidb cdc时发现不能获取全表数据

show table region发现并没有该region id

麻烦大佬关注下解答下,谢谢!

1赞

查看TIKV_REGION_STATUS表发现大量region没有table, db信息

其中就包括我上面的报错的regionid 53599

1赞

请问 flink tidb cdc 指的是哪个项目?

1赞

麻烦提供一下更详细的信息。

  • 使用的版本
  • 复现的方式
1赞

https://github.com/ververica/flink-cdc-connectors就是这个项目

1赞

tikv-java的版本为3.2.0

1赞

为啥要自己写一个 Scan

1赞

这是使用flink tidb cdc的时候出错的时候,我扣出的代码用于调试的,是不是现在tikv-java里已经有了对于单表进行scan的函数

1赞

需要获取单表的全量数据,所以有一个scan

1赞

可以试一试
https://github.com/tidb-incubator/TiBigData/blob/master/flink/README_unified_batch_streaming_zh_CN.md

1赞

嗯,我看下,这个好像是走的jdbc从tidb里获取全量数据。
谢谢!!!

1赞

对了,为什么为会有region不对应table的存在

不是很清楚 flink-cdc-connectors 那边是怎么写的,可以去提个 issue 问一问?

这个是数据库中查到的