code: @Override
    public void abortTask(TaskAttemptContext context) throws IOException {
      try {
        if (workPath != null) { 
          context.progress();
          if (!outputFileSystem.delete(workPath, true)) {
            LOG.warn("Deleting output in " + workPath + " returns false");
          }
        }
      } catch (IOException ie) {
        LOG.warn("Error discarding output in " + workPath, ie);
        throw ie;
      }
    }
docs: Delete the work directory