[HBASE-18197] Avoided to call job.waitForCompletion(true) two times

• Type: Bug
• Status: Resolved
• Priority: Trivial
• Resolution: Fixed
• Affects Version/s: 1.0.2, 1.2.0, 1.4.0
• Fix Version/s: 1.4.0, 1.3.2, 1.2.7
• Hadoop Flags: Reviewed
• Assignee: Jan Hentschel
• Reporter: Chandra Sekhar
• Created: 09/Jun/17 07:01
• Updated: 02/Oct/19 17:28
• Resolved: 11/Aug/17 18:49

Description

import.java, job output is printing two times.

after job completed, job.waitForCompletion(true) is calling two times.

Job job = createSubmittableJob(conf, otherArgs);
    boolean isJobSuccessful = job.waitForCompletion(true);
    if(isJobSuccessful){
      // Flush all the regions of the table
      flushRegionsIfNecessary(conf);
    }
    long inputRecords = job.getCounters().findCounter(TaskCounter.MAP_INPUT_RECORDS).getValue();
    long outputRecords = job.getCounters().findCounter(TaskCounter.MAP_OUTPUT_RECORDS).getValue();
    if (outputRecords < inputRecords) {
      System.err.println("Warning, not all records were imported (maybe filtered out).");
      if (outputRecords == 0) {
        System.err.println("If the data was exported from HBase 0.94 "+
            "consider using -Dhbase.import.version=0.94.");
      }
    }

    System.exit(job.waitForCompletion(true) ? 0 : 1);

Issue Links

• links to: Review Board (branch-1.0)
• links to: Review Board (branch-1.2)