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

[ML] Some logging improvements 

- Downgrade flush logging as it's called too often from datafeeds
- Add log info for job opening

Original commit: elastic/x-pack-elasticsearch@a262069f78
This commit is contained in:
Dimitrios Athanasiou 2017-04-07 13:35:26 +01:00
parent df3cc61c5b
commit b41288592c
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java
View File

@ -184,7 +184,7 @@ public class AutodetectCommunicator implements Closeable {
// clients from querying results in the middle of normalization. // clients from querying results in the middle of normalization.
autoDetectResultProcessor.waitUntilRenormalizerIsIdle(); autoDetectResultProcessor.waitUntilRenormalizerIsIdle();
LOGGER.info("[{}] Flush completed", job.getId()); LOGGER.debug("[{}] Flush completed", job.getId());
} }
/** /**

1
plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectProcessManager.java
View File

@ -204,6 +204,7 @@ public class AutodetectProcessManager extends AbstractComponent {
} }
public void openJob(String jobId, JobTask jobTask, boolean ignoreDowntime, Consumer<Exception> handler) { public void openJob(String jobId, JobTask jobTask, boolean ignoreDowntime, Consumer<Exception> handler) {
logger.info("Opening job [{}]", jobId);
Job job = jobManager.getJobOrThrowIfUnknown(jobId); Job job = jobManager.getJobOrThrowIfUnknown(jobId);
jobProvider.getAutodetectParams(job, params -> { jobProvider.getAutodetectParams(job, params -> {
// We need to fork, otherwise we restore model state from a network thread (several GET api calls): // We need to fork, otherwise we restore model state from a network thread (several GET api calls):