HBASE-13532 Make UnknownScannerException less scary by giving more information in the exception string. (Apekshit)
Signed-off-by: Matteo Bertozzi <matteo.bertozzi@cloudera.com>
This commit is contained in:
parent
0e281e1929
commit
60e19f60a9
|
@ -2542,9 +2542,14 @@ public class RSRpcServices implements HBaseRPCErrorHandler,
|
||||||
if (request.hasScannerId()) {
|
if (request.hasScannerId()) {
|
||||||
rsh = scanners.get(scannerName);
|
rsh = scanners.get(scannerName);
|
||||||
if (rsh == null) {
|
if (rsh == null) {
|
||||||
LOG.info("Client tried to access missing scanner " + scannerName);
|
LOG.warn("Client tried to access missing scanner " + scannerName);
|
||||||
throw new UnknownScannerException(
|
throw new UnknownScannerException(
|
||||||
"Name: " + scannerName + ", already closed?");
|
"Unknown scanner '" + scannerName + "'. This can happen due to any of the following "
|
||||||
|
+ "reasons: a) Scanner id given is wrong, b) Scanner lease expired because of "
|
||||||
|
+ "long wait between consecutive client checkins, c) Server may be closing down, "
|
||||||
|
+ "d) RegionServer restart during upgrade.\nIf the issue is due to reason (b), a "
|
||||||
|
+ "possible fix would be increasing the value of"
|
||||||
|
+ "'hbase.client.scanner.timeout.period' configuration.");
|
||||||
}
|
}
|
||||||
scanner = rsh.s;
|
scanner = rsh.s;
|
||||||
HRegionInfo hri = scanner.getRegionInfo();
|
HRegionInfo hri = scanner.getRegionInfo();
|
||||||
|
|
Loading…
Reference in New Issue