@Override
    public void run() {
      while (run) {
        try {
          LOG.info("MOB cleanup started ...");
          MobFileCleanupUtil.cleanupObsoleteMobFiles(conf, table.getName(), admin);
          LOG.info("MOB cleanup finished");

          Thread.sleep(130000);
        } catch (Exception e) {
          LOG.error("CleanMobAndArchive", e);
        }
      }
    }
Reproduction for MOB data loss 1. Settings: Region Size 200 MB, Flush threshold 800 KB. 2. Insert
10 Million records 3. MOB Compaction and Archiver a) Trigger MOB Compaction (every 2 minutes) b)
Trigger major compaction (every 2 minutes) c) Trigger archive cleaner (every 3 minutes) 4.
Validate MOB data after complete data load. This class is used by MobStressTool only. This is not
a unit test
hbase-server/src/test/java/org/apache/hadoop/hbase/mob/MobStressToolRunner.java