diff --git a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java index 97f246223a6f..d2086dfb1c43 100644 --- a/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java +++ b/pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/minion/PinotTaskManager.java @@ -47,7 +47,6 @@ import org.apache.pinot.common.minion.TaskManagerStatusCache; import org.apache.pinot.controller.ControllerConf; import org.apache.pinot.controller.LeadControllerManager; -import org.apache.pinot.controller.api.exception.NoTaskScheduledException; import org.apache.pinot.controller.api.exception.TaskAlreadyExistsException; import org.apache.pinot.controller.api.exception.UnknownTaskTypeException; import org.apache.pinot.controller.helix.core.PinotHelixResourceManager; @@ -212,7 +211,7 @@ public Map createTask(String taskType, String tableName, @Nullab taskGenerator.getMaxAttemptsPerTask())); } if (responseMap.isEmpty()) { - throw new NoTaskScheduledException("No task scheduled for 'tableName': " + tableName); + LOGGER.warn("No task submitted for tableName: {}", tableName); } return responseMap; }