|
@@ -499,8 +499,12 @@ public class EditLogTailer {
|
|
|
|
|
|
currentNN = nnLookup.next();
|
|
|
try {
|
|
|
+ int rpcTimeout = conf.getInt(
|
|
|
+ DFSConfigKeys.DFS_HA_LOGROLL_RPC_TIMEOUT_KEY,
|
|
|
+ DFSConfigKeys.DFS_HA_LOGROLL_RPC_TIMEOUT_DEFAULT);
|
|
|
NamenodeProtocolPB proxy = RPC.waitForProxy(NamenodeProtocolPB.class,
|
|
|
- RPC.getProtocolVersion(NamenodeProtocolPB.class), currentNN.getIpcAddress(), conf);
|
|
|
+ RPC.getProtocolVersion(NamenodeProtocolPB.class), currentNN.getIpcAddress(), conf,
|
|
|
+ rpcTimeout, Long.MAX_VALUE);
|
|
|
cachedActiveProxy = new NamenodeProtocolTranslatorPB(proxy);
|
|
|
break;
|
|
|
} catch (IOException e) {
|