From 16d8dc68156947aa8efbd1c587e693fc4240f664 Mon Sep 17 00:00:00 2001
From: Dimitrios Athanasiou <dimitris@elastic.co>
Date: Sat, 8 Apr 2017 15:14:58 +0100
Subject: [PATCH] [ML] Log when no node found to open job/start datafeed

Relates elastic/x-pack-elasticsearch#878

Original commit: elastic/x-pack-elasticsearch@a64b7eaa80dbd2ac8980ae17b0b05fa0627a9012
---
 .../org/elasticsearch/xpack/ml/action/OpenJobAction.java    | 1 +
 .../elasticsearch/xpack/ml/action/StartDatafeedAction.java  | 6 ++++--
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java
index 3d12f85da42..cdcd965abf3 100644
--- a/plugin/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java
+++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java
@@ -407,6 +407,7 @@ public class OpenJobAction extends Action<OpenJobAction.Request, OpenJobAction.R
                 if (assignment.getExecutorNode() == null) {
                     String msg = "Could not open job because no suitable nodes were found, allocation explanation ["
                             + assignment.getExplanation() + "]";
+                    logger.warn("[{}] {}", msg);
                     auditor.warning(request.getJobId(), msg);
                     throw new ElasticsearchStatusException(msg, RestStatus.TOO_MANY_REQUESTS);
                 }
diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java
index 74605d2de26..480e8032c79 100644
--- a/plugin/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java
+++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java
@@ -461,8 +461,10 @@ public class StartDatafeedAction
                     DatafeedConfig datafeed = mlMetadata.getDatafeed(datafeedId);
                     String jobId = datafeed.getJobId();
                     if (assignment.getExecutorNode() == null) {
-                        auditor.warning(jobId, "No node found to start datafeed [" + datafeedId +"]. Reasons [" +
-                                assignment.getExplanation() + "]");
+                        String msg = "No node found to start datafeed [" + datafeedId +"]. Reasons [" +
+                                assignment.getExplanation() + "]";
+                        logger.warn(msg);
+                        auditor.warning(jobId, msg);
                     } else {
                         DiscoveryNode node = state.nodes().get(assignment.getExecutorNode());
                         auditor.info(jobId, "Starting datafeed [" + datafeedId + "] on node [" + node + "]");