[ML] Improve state persistence log message

davidkyle · davidkyle · commit 9dd629648dd9 · 2018-05-12T09:20:08.000+01:00
diff --git a/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/output/StateProcessor.java b/x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/output/StateProcessor.java
@@ -91,10 +91,10 @@ private BytesReference splitAndPersist(String jobId, BytesReference bytesRef, in
     }
 
     void persist(String jobId, BytesReference bytes) throws IOException {
-        logger.trace("[{}] ES API CALL: bulk index", jobId);
         BulkRequest bulkRequest = new BulkRequest();
         bulkRequest.add(bytes, AnomalyDetectorsIndex.jobStateIndexName(), ElasticsearchMappings.DOC_TYPE, XContentType.JSON);
         if (bulkRequest.numberOfActions() > 0) {
+            logger.trace("[{}] Persisting job state document", jobId);
             try (ThreadContext.StoredContext ignore = stashWithOrigin(client.threadPool().getThreadContext(), ML_ORIGIN)) {
                 client.bulk(bulkRequest).actionGet();
             }

Original file line number	Diff line number	Diff line change
`@@ -91,10 +91,10 @@ private BytesReference splitAndPersist(String jobId, BytesReference bytesRef, in`
`91`	`91`	`}`
`92`	`92`
`93`	`93`	`void persist(String jobId, BytesReference bytes) throws IOException {`
`94`		`- logger.trace("[{}] ES API CALL: bulk index", jobId);`
`95`	`94`	`BulkRequest bulkRequest = new BulkRequest();`
`96`	`95`	`bulkRequest.add(bytes, AnomalyDetectorsIndex.jobStateIndexName(), ElasticsearchMappings.DOC_TYPE, XContentType.JSON);`
`97`	`96`	`if (bulkRequest.numberOfActions() > 0) {`
	`97`	`+ logger.trace("[{}] Persisting job state document", jobId);`
`98`	`98`	`try (ThreadContext.StoredContext ignore = stashWithOrigin(client.threadPool().getThreadContext(), ML_ORIGIN)) {`
`99`	`99`	`client.bulk(bulkRequest).actionGet();`
`100`	`100`	`}`