@Override
      public void run() {
        try {
          analyticJobGenerator.fetchJobsFromSecondRetryQueue(appList);
        } catch (ConcurrentModificationException e) {
          cmExceptionFlag.set(true);
        }
      }
Tests concurrent operations (fetch and add) on second retry queue.
test/com/linkedin/drelephant/analysis/AnalyticJobGeneratorHadoop2Test.java