alert when task fails in RTR assign

9d0e4a94 · fjy · db695f49 · 9d0e4a94
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java ...m/metamx/druid/indexing/coordinator/RemoteTaskRunner.java +3 -1

未找到文件。
--- a/indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java
+++ b/indexing-service/src/main/java/com/metamx/druid/indexing/coordinator/RemoteTaskRunner.java
@@ -472,7 +472,9 @@ public class RemoteTaskRunner implements TaskRunner, TaskLogProvider
      }
    }
    catch (Exception e) {
-      throw Throwables.propagate(e);
+      log.makeAlert("Exception while trying to run task")
+      .addData("taskId", taskRunnerWorkItem.getTask().getId())
+      .emit();
    }
  }