private void forceReinsertIntoQueue(TaskWrapper taskWrapper, boolean isRemoved) {
    if (!isRemoved) {
      LOG.warn("Failed to remove {} from waitQueue", taskWrapper.getTaskRunnerCallable());
    } else {
      waitQueue.forceOffer(taskWrapper);
    }
  }
Worker that takes tasks from wait queue and schedule it for execution.
llap-server/src/java/org/apache/hadoop/hive/llap/daemon/impl/TaskExecutorService.java