honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[ML] Add notification when no suitable nodes exist to allocate job (elastic/x-pack-elasticsearch#1006) 

Relates elastic/x-pack-elasticsearch#878

Original commit: elastic/x-pack-elasticsearch@5a96484662
This commit is contained in:
Dimitris Athanasiou 2017-04-07 16:55:10 +01:00 committed by GitHub
parent 3986235d93
commit bf111dde7e
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
plugin/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java
View File

@ -405,8 +405,10 @@ public class OpenJobAction extends Action<OpenJobAction.Request, OpenJobAction.R
OpenJobAction.validate(request.getJobId(), mlMetadata, tasks);
Assignment assignment = selectLeastLoadedMlNode(request.getJobId(), clusterState, maxConcurrentJobAllocations, logger);
if (assignment.getExecutorNode() == null) {
throw new ElasticsearchStatusException("cannot open job [" + request.getJobId() + "], no suitable nodes found, " +
"allocation explanation [{}]", RestStatus.TOO_MANY_REQUESTS, assignment.getExplanation());
String msg = "Could not open job because no suitable nodes were found, allocation explanation ["
+ assignment.getExplanation() + "]";
auditor.warning(request.getJobId(), msg);
throw new ElasticsearchStatusException(msg, RestStatus.TOO_MANY_REQUESTS);
}
} else {
throw LicenseUtils.newComplianceException(XPackPlugin.MACHINE_LEARNING);
@ -447,7 +449,7 @@ public class OpenJobAction extends Action<OpenJobAction.Request, OpenJobAction.R
auditor.warning(jobId, "No node found to open job. Reasons [" + assignment.getExplanation() + "]");
} else {
DiscoveryNode node = state.nodes().get(assignment.getExecutorNode());
auditor.info(jobId, "Found node [" + node + "] to open job");
auditor.info(jobId, "Opening job on node [" + node.toString() + "]");
}
}
});

2
plugin/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java
View File

@ -465,7 +465,7 @@ public class StartDatafeedAction
assignment.getExplanation() + "]");
} else {
DiscoveryNode node = state.nodes().get(assignment.getExecutorNode());
auditor.info(jobId, "Found node [" + node + "] to start datafeed [" + datafeedId + "]");
auditor.info(jobId, "Starting datafeed [" + datafeedId + "] on node [" + node + "]");
}
}
});