HBASE-14313 After a Connection sees ConnectionClosingException it never recovers -- ADDENDUM

This commit is contained in:
Elliott Clark 2015-08-26 22:28:38 -07:00
parent 886542bd1b
commit ab47cb9569
1 changed files with 3 additions and 1 deletions

View File

@ -939,7 +939,9 @@ public class RpcClientImpl extends AbstractRpcClient {
} catch (IOException e) { } catch (IOException e) {
// We set the value inside the synchronized block, this way the next in line // We set the value inside the synchronized block, this way the next in line
// won't even try to write // won't even try to write
markClosed(e); if (markClosed(e)) {
close();
}
writeException = e; writeException = e;
interrupt(); interrupt();
} }