Skip to content

Commit e5042be

Browse files
mihir6692virajjasani
authored andcommitted
HBASE-28357 MoveWithAck#isSuccessfulScan for Region movement should use Region End Key for limiting scan to one region only. (#5677)
Signed-off-by: Viraj Jasani <vjasani@apache.org>
1 parent b27e7c7 commit e5042be

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithAck.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,8 +110,9 @@ private static String getTimeDiffInSec(long startTime) {
110110
* Tries to scan a row from passed region
111111
*/
112112
private void isSuccessfulScan(RegionInfo region) throws IOException {
113-
Scan scan = new Scan().withStartRow(region.getStartKey()).setRaw(true).setOneRowLimit()
114-
.setMaxResultSize(1L).setCaching(1).setFilter(new FirstKeyOnlyFilter()).setCacheBlocks(false);
113+
Scan scan = new Scan().withStartRow(region.getStartKey()).withStopRow(region.getEndKey(), false)
114+
.setRaw(true).setOneRowLimit().setMaxResultSize(1L).setCaching(1)
115+
.setFilter(new FirstKeyOnlyFilter()).setCacheBlocks(false);
115116
try (Table table = conn.getTable(region.getTable());
116117
ResultScanner scanner = table.getScanner(scan)) {
117118
scanner.next();

0 commit comments

Comments
 (0)