diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java index bff251b09b1a..9a7f2905b110 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/ForkingTaskRunner.java @@ -521,9 +521,21 @@ int waitForTaskProcessToComplete(Task task, ProcessHolder processHolder, File lo finally { Thread.currentThread().setName(priorThreadName); // Upload task logs - taskLogPusher.pushTaskLog(task.getId(), logFile); + try { + taskLogPusher.pushTaskLog(task.getId(), logFile); + } + catch (IOException e) { + LOGGER.error("Task[%s] failed to push task logs to [%s]: Exception[%s]", + task.getId(), logFile.getName(), e.getMessage()); + } if (reportsFile.exists()) { - taskLogPusher.pushTaskReports(task.getId(), reportsFile); + try { + taskLogPusher.pushTaskReports(task.getId(), reportsFile); + } + catch (IOException e) { + LOGGER.error("Task[%s] failed to push task reports to [%s]: Exception[%s]", + task.getId(), reportsFile.getName(), e.getMessage()); + } } } }