From d91d1c869910c1df44aa231adb52d625f53e8688 Mon Sep 17 00:00:00 2001 From: Himanshu Date: Fri, 4 Oct 2019 09:42:20 -0700 Subject: [PATCH] make TaskMonitor continue to monitor in the face of transient errors (#8625) --- .../indexing/common/task/batch/parallel/TaskMonitor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TaskMonitor.java b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TaskMonitor.java index 33cc804d056..e4065d27881 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TaskMonitor.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/TaskMonitor.java @@ -164,8 +164,10 @@ public class TaskMonitor } } catch (Throwable t) { + // Note that we only log the message here so that task monitoring continues to happen or else + // the task which created this monitor will keep on waiting endlessly assuming monitored tasks + // are still running. log.error(t, "Error while monitoring"); - throw t; } }, taskStatusCheckingPeriod,