@Override
    protected Void callInternal() {
      Path pathToDelete = new Path(dirToDelete);
      LOG.debug("Deleting path: {}", pathToDelete);
      try {
        localFs.delete(new Path(dirToDelete), true);
      } catch (IOException e) {
        LOG.warn("Ignoring exception while cleaning up path: " + pathToDelete, e);
      }
      return null;
    }
Register an update to a source within an executing dag
@param queryIdentifier
@param sourceName
@param sourceState
llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/QueryTracker.java