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

HBASE-16132 Scan does not return all the result when regionserver is busy (binlijin)

This commit is contained in:
Yu Li 2016-07-04 21:43:29 +08:00
parent 4807836304
commit 84dd9cbcb6
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-client/src/main/java/org/apache/hadoop/hbase/client/ScannerCallableWithReplicas.java
View File

@ -202,6 +202,9 @@ class ScannerCallableWithReplicas implements RetryingCallable<Result[]> {
updateCurrentlyServingReplica(r.getSecond(), r.getFirst(), done, pool); updateCurrentlyServingReplica(r.getSecond(), r.getFirst(), done, pool);
} }
return r == null ? null : r.getFirst(); // great we got an answer return r == null ? null : r.getFirst(); // great we got an answer
} else {
throw new IOException("Failed to get result within timeout, timeout="
+ timeout + "ms");
} }
} catch (ExecutionException e) { } catch (ExecutionException e) {
RpcRetryingCallerWithReadReplicas.throwEnrichedException(e, retries); RpcRetryingCallerWithReadReplicas.throwEnrichedException(e, retries);
@ -216,7 +219,8 @@ class ScannerCallableWithReplicas implements RetryingCallable<Result[]> {
// calls succeeded or failed. In all case, we stop all our tasks. // calls succeeded or failed. In all case, we stop all our tasks.
cs.cancelAll(); cs.cancelAll();
} }
return null; // unreachable LOG.error("Imposible? Arrive at an unreachable line..."); // unreachable
throw new IOException("Imposible? Arrive at an unreachable line...");
} }
private void updateCurrentlyServingReplica(ScannerCallable scanner, Result[] result, private void updateCurrentlyServingReplica(ScannerCallable scanner, Result[] result,

3
hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMasterCommandLine.java
View File

@ -101,8 +101,7 @@ public class HMasterCommandLine extends ServerCommandLine {
// minRegionServers used to be minServers. Support it too. // minRegionServers used to be minServers. Support it too.
if (cmd.hasOption("minServers")) { if (cmd.hasOption("minServers")) {
String val = cmd.getOptionValue("minServers"); String val = cmd.getOptionValue("minServers");
getConf().setInt("hbase.regions.server.count.min", getConf().setInt("hbase.regions.server.count.min", Integer.parseInt(val));
Integer.parseInt(val));
LOG.debug("minServers set to " + val); LOG.debug("minServers set to " + val);
} }