This is an automated email from the ASF dual-hosted git repository.
frankchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new fa562a2c6e6 Ignore exceptions when pushing task logs to ensure task
success (#18210)
fa562a2c6e6 is described below
commit fa562a2c6e61c1176c8ac75f4d506a4546b0b18d
Author: Virushade <[email protected]>
AuthorDate: Fri Jul 11 17:11:28 2025 +0800
Ignore exceptions when pushing task logs to ensure task success (#18210)
* Ignore exceptions when pushing task logs to ensure task success
* Log exception message when pushing to tasklog failed
---
.../druid/indexing/overlord/ForkingTaskRunner.java | 16 ++++++++++++++--
1 file changed, 14 insertions(+), 2 deletions(-)
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 bff251b09b1..9a7f2905b11 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 @@ public class ForkingTaskRunner
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());
+ }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
