Skip to content

Commit 8b6f8a2

Browse files
committed
apply patch OpenTSDB#202
1 parent c07d5db commit 8b6f8a2

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/RegionClient.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1547,6 +1547,7 @@ protected Object decode(final ChannelHandlerContext ctx,
15471547
final class RetryTimer implements TimerTask {
15481548
public void run(final Timeout timeout) {
15491549
if (isAlive()) {
1550+
rpc.attempt++;
15501551
sendRpc(rpc);
15511552
} else {
15521553
if (rpc instanceof MultiAction) {

src/UnknownScannerException.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
/**
3030
* Exception thrown when we try to use an invalid or expired scanner ID.
3131
*/
32-
public final class UnknownScannerException extends RecoverableException
32+
public final class UnknownScannerException extends NonRecoverableException
3333
implements HasFailedRpcException {
3434

3535
static final String REMOTE_CLASS =

0 commit comments

Comments
 (0)