Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16090 ResultScanner is not closed in SyncTable#finishRemainingHashRanges()

This commit is contained in:
tedyu 2016-06-23 07:29:34 -07:00
parent 339cb81747
commit 857ec2f448
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/SyncTable.java
View File

@ -654,9 +654,16 @@ public class SyncTable extends Configured implements Tool {
scan.setStopRow(nextSourceKey.copyBytes()); scan.setStopRow(nextSourceKey.copyBytes());
} }
ResultScanner targetScanner = targetTable.getScanner(scan); ResultScanner targetScanner = null;
for (Result row : targetScanner) { try {
targetHasher.hashResult(row); targetScanner = targetTable.getScanner(scan);
for (Result row : targetScanner) {
targetHasher.hashResult(row);
}
} finally {
if (targetScanner != null) {
targetScanner.close();
}
} }
} // else current batch ends exactly at split end row } // else current batch ends exactly at split end row