otsStreamReader 源数据表发生分区变动后,同步数据报错
- Dominant language
- Java
- Stars
- 17.4k
- Forks
- 5.7k
- PR merge metrics
- No merged PRs in 30d
Description
当ots的表发生分区合并后ots.describeStream api返回的shardList 包含父shareId信息时 otsStreamReader 运行报错;
报错结果如下:


报错原码位置:

ots.describeStream api返回的shardList数据如下:

Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reading the otsStreamReader code at the reported error location and compare its shardList handling with ots.describeStream responses after a partition merge. Reproduce the parent-shard case and verify that synchronization completes without the reported error.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- databases
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 38/100