|
@@ -154,8 +154,10 @@ public class DatanodeManager {
|
|
|
DFSConfigKeys.DFS_NAMENODE_HEARTBEAT_RECHECK_INTERVAL_DEFAULT); // 5 minutes
|
|
|
this.heartbeatExpireInterval = 2 * heartbeatRecheckInterval
|
|
|
+ 10 * 1000 * heartbeatIntervalSeconds;
|
|
|
- this.blockInvalidateLimit = Math.max(20*(int)(heartbeatIntervalSeconds),
|
|
|
+ final int blockInvalidateLimit = Math.max(20*(int)(heartbeatIntervalSeconds),
|
|
|
DFSConfigKeys.DFS_BLOCK_INVALIDATE_LIMIT_DEFAULT);
|
|
|
+ this.blockInvalidateLimit = conf.getInt(
|
|
|
+ DFSConfigKeys.DFS_BLOCK_INVALIDATE_LIMIT_KEY, blockInvalidateLimit);
|
|
|
LOG.info(DFSConfigKeys.DFS_BLOCK_INVALIDATE_LIMIT_KEY
|
|
|
+ "=" + this.blockInvalidateLimit);
|
|
|
}
|