// 調(diào)度任務(wù)：fsImageCheckpointer
defaultScheduler.schedule("FSImage Checkpoint操作", fsImageCheckpointer,
        backupnodeConfig.getCheckpointInterval(), backupnodeConfig.getCheckpointInterval(), TimeUnit.MILLISECONDS);

/**
 * checkpoint 任務(wù)
 */
@Override
public void run() {
    log.info("BackupNode啟動checkpoint后臺線程.");
    try {
        // 如果是正在恢復(fù)元數(shù)據(jù)，則直接返回
        if (nameSystem.isRecovering()) {
            log.info("正在恢復(fù)元數(shù)據(jù)...");
            return;
        }
        // 當(dāng)前 maxid 和 之前記錄的 maxid 相等
        if (nameSystem.getMaxTxId() == lastCheckpointTxId) {
            log.info("EditLog和上次沒有變化，不進(jìn)行checkpoint: [txId={}]", lastCheckpointTxId);
            return;
        }
        // 以下討論的情況是：當(dāng)前 maxid 和 之前記錄的 maxid 不相等（大于）
        // 對當(dāng)前內(nèi)存中的數(shù)據(jù)生成快照
        FsImage fsImage = nameSystem.getFsImage();
        // 更新記錄中的 maxid
        lastCheckpointTxId = fsImage.getMaxTxId();
        // 路徑
        String fsImageFile = backupNodeConfig.getFsImageFile(String.valueOf(System.currentTimeMillis()));
        log.info("開始執(zhí)行checkpoint操作: [maxTxId={}]", fsImage.getMaxTxId());
        // 寫入FsImage文件
        doCheckpoint(fsImage, fsImageFile);
        // 上傳 FsImage 給 NameNode
        uploadFsImage(fsImageFile);
        // 刪除舊的FSImage
        namenodeClient.getDefaultScheduler().scheduleOnce("刪除FSImage任務(wù)", fsImageClearTask, 0);
    } catch (Exception e) {
        log.error("FSImageCheckPointer error:", e);
    }
}