BlockManager内有个ReplicationMonitor线程类。

配置

  • dfs.namenode.replication.interval:默认3秒。
  • dfs.namenode.replication.work.multiplier.per.iteration:默认2。
  • dfs.namenode.invalidate.work.pct.per.iteration:默认0.32f。
  • dfs.namenode.replication.max-streams-hard-limit
  • dfs.namenode.replication.max-streams