From b41288592c0fafa146bc1bcd18ccfb66f0d483fa Mon Sep 17 00:00:00 2001 From: Dimitrios Athanasiou Date: Fri, 7 Apr 2017 13:35:26 +0100 Subject: [PATCH] [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@a262069f78e7dfb8fb1b20b8c3717331ff95aa37 --- .../xpack/ml/job/process/autodetect/AutodetectCommunicator.java | 2 +- .../ml/job/process/autodetect/AutodetectProcessManager.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java index 6b4d7e94b62..b39a1cad516 100644 --- a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java +++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectCommunicator.java @@ -184,7 +184,7 @@ public class AutodetectCommunicator implements Closeable { // clients from querying results in the middle of normalization. autoDetectResultProcessor.waitUntilRenormalizerIsIdle(); - LOGGER.info("[{}] Flush completed", job.getId()); + LOGGER.debug("[{}] Flush completed", job.getId()); } /** diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectProcessManager.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectProcessManager.java index b4627847ee4..9b8e2e53ae0 100644 --- a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectProcessManager.java +++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/AutodetectProcessManager.java @@ -204,6 +204,7 @@ public class AutodetectProcessManager extends AbstractComponent { } public void openJob(String jobId, JobTask jobTask, boolean ignoreDowntime, Consumer handler) { + logger.info("Opening job [{}]", jobId); Job job = jobManager.getJobOrThrowIfUnknown(jobId); jobProvider.getAutodetectParams(job, params -> { // We need to fork, otherwise we restore model state from a network thread (several GET api calls):