hadoop/src/main/java/org/apache/carbondata/hadoop/api/CarbonOutputCommitter.java
/**
   * Update the tablestatus as fail if any fail happens.
   *
   * @param context
   * @param state
   * @throws IOException
   */
Update the tablestatus as fail if any fail happens.
@param context
@param state
@throws IOException
Update the tablestatus as fail if any fail happens . @param context @param state @throws IOException
@Override public void abortJob(JobContext context, JobStatus.State state) throws IOException {
    super.abortJob(context, state);
    CarbonLoadModel loadModel = CarbonTableOutputFormat.getLoadModel(context.getConfiguration());
    CarbonLoaderUtil.updateTableStatusForFailure(loadModel);
    LOGGER.error("Loading failed with job status : " + state);
  }
@ Override public void abortJob ( JobContext context , JobStatus . State state ) throws IOException { super . abortJob ( context , state ) ; CarbonLoadModel loadModel = CarbonTableOutputFormat . getLoadModel ( context . getConfiguration ( ) ) ; CarbonLoaderUtil . updateTableStatusForFailure ( loadModel ) ; LOGGER . error ( "Loading failed with job status : " + state ) ; }
Update the tablestatus as fail if any fail happens.
Update the tablestatus as fail if any fail happens .