diff --git llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java index 6fa3107..efd774d 100644 --- llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java +++ llap-tez/src/java/org/apache/hadoop/hive/llap/tezplugins/LlapTaskSchedulerService.java @@ -870,6 +870,9 @@ private void disableInstance(ServiceInstance instance, boolean isCommFailure) { if (metrics != null) { metrics.setDisabledNodeCount(disabledNodesQueue.size()); } + // Trigger a scheduling run - in case there's some task which was waiting for this node to + // become available. + trySchedulingPendingTasks(); } } finally { writeLock.unlock();