public synchronized void abortTask(TaskAttemptContext context) throws IOException {
    String key = generateKey(context);
    if (!taskCommitters.containsKey(key)) {
      LOG.warn("No callback registered for TaskAttemptID:" + key + ". Skipping.");
      return;
    }

    try {
      LOG.info("Aborting TaskAttempt:" + key);
      taskCommitters.get(key).abortTask(context);
    }
    catch (Throwable t) {
      throw new IOException("Could not clean up TaskAttemptID:" + key, t);
    }
  }
Trigger abort for TaskAttempt, as specified by the TaskAttemptContext argument.
hcatalog/core/src/main/java/org/apache/hive/hcatalog/mapreduce/TaskCommitContextRegistry.java