今天来填在Hadoop HA 状态转换源码分析中留下的坑。

editLogTailer是一个编辑日志edit log的追踪器,它的主要作用就是当NameNode处于standby状态时用于从共享的edit log读取数据。它的构造是在FSNamesystem的startStandbyServices()方法中,代码如下:

EditLogTailer类源码解析

调用了start方法,追到start方法:

EditLogTailer类源码解析

启动了EditLogTailer类里面的tailerThread这个线程。

所以我们就去看tailerThread的run方法,run方法,最终调用了doWork方法。

EditLogTailer类源码解析

追到doWork方法:

EditLogTailer类源码解析

shouldRun为true时一直循环,这个shouldRun是个volatile的boolean值,初始为true,只有调用EditLogTailer#stop方法的时候才会设为false。

接下来看while循环里:

自从上次日志滚动触发以来,如果StandBy NameNode没有读到任何事务的话,就没有必要触发一次日志滚动,如果是自从上次加载后过了太长时间,并且上次编辑日志滚动开始时的最新事务ID小于StandBy NameNode加载的最大事务ID,那么就去触发一次Active NN的log roll。

然后去调用了doTailEdits()方法去追踪editlog。

最后休眠sleepTimeMs毫秒,这个sleepTimeMs == "dfs.ha.tail-edits.period" * 1000

EditLogTailer类源码解析

相关文章:

  • 2021-10-10
  • 2021-09-30
  • 2021-09-03
  • 2022-12-23
  • 2021-11-18
  • 2021-12-03
  • 2021-11-22
  • 2021-06-16
猜你喜欢
  • 2021-06-09
  • 2022-01-12
  • 2021-11-02
  • 2021-08-19
  • 2022-01-19
  • 2021-07-05
  • 2021-10-04
相关资源
相似解决方案