@Override
  public void serviceStop() {
    executorService.shutdown();
    try {
      executorService.awaitTermination(10000, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
      LOG.warn("cannot finish QueryTracker cleanup because of InterruptedException", e);
    }
    LOG.info(getName() + " stopped");
  }
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