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

[ML] Add missing job Ids to log messages 

Original commit: elastic/x-pack-elasticsearch@56855a3808
This commit is contained in:
David Kyle 2017-12-05 17:43:34 +00:00
parent 751caaae76
commit 4cd8f075b9
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/src/main/java/org/elasticsearch/xpack/ml/datafeed/DatafeedJob.java
View File

@ -118,7 +118,7 @@ class DatafeedJob {
} }
} }
if (!isIsolated) { if (!isIsolated) {
LOGGER.debug("Lookback finished after being stopped"); LOGGER.debug("[{}] Lookback finished after being stopped", jobId);
} }
return null; return null;
} }
@ -133,7 +133,7 @@ class DatafeedJob {
FlushJobAction.Request request = new FlushJobAction.Request(jobId); FlushJobAction.Request request = new FlushJobAction.Request(jobId);
request.setSkipTime(String.valueOf(startTime)); request.setSkipTime(String.valueOf(startTime));
FlushJobAction.Response flushResponse = flushJob(request); FlushJobAction.Response flushResponse = flushJob(request);
LOGGER.info("Skipped to time [" + flushResponse.getLastFinalizedBucketEnd().getTime() + "]"); LOGGER.info("[{}] Skipped to time [{}]", jobId, flushResponse.getLastFinalizedBucketEnd().getTime());
return flushResponse.getLastFinalizedBucketEnd().getTime(); return flushResponse.getLastFinalizedBucketEnd().getTime();
} }
return startTime; return startTime;

6
plugin/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/chunked/ChunkedDataExtractor.java
View File

@ -98,8 +98,8 @@ public class ChunkedDataExtractor implements DataExtractor {
currentEnd = currentStart; currentEnd = currentStart;
chunkSpan = context.chunkSpan == null ? dataSummary.estimateChunk() : context.chunkSpan.getMillis(); chunkSpan = context.chunkSpan == null ? dataSummary.estimateChunk() : context.chunkSpan.getMillis();
chunkSpan = context.timeAligner.alignToCeil(chunkSpan); chunkSpan = context.timeAligner.alignToCeil(chunkSpan);
LOGGER.debug("Chunked search configured: totalHits = {}, dataTimeSpread = {} ms, chunk span = {} ms", LOGGER.debug("[{}]Chunked search configured: totalHits = {}, dataTimeSpread = {} ms, chunk span = {} ms",
dataSummary.totalHits, dataSummary.getDataTimeSpread(), chunkSpan); context.jobId, dataSummary.totalHits, dataSummary.getDataTimeSpread(), chunkSpan);
} else { } else {
// search is over // search is over
currentEnd = context.end; currentEnd = context.end;
@ -164,7 +164,7 @@ public class ChunkedDataExtractor implements DataExtractor {
currentStart = currentEnd; currentStart = currentEnd;
currentEnd = Math.min(currentStart + chunkSpan, context.end); currentEnd = Math.min(currentStart + chunkSpan, context.end);
currentExtractor = dataExtractorFactory.newExtractor(currentStart, currentEnd); currentExtractor = dataExtractorFactory.newExtractor(currentStart, currentEnd);
LOGGER.trace("advances time to [{}, {})", currentStart, currentEnd); LOGGER.trace("[{}] advances time to [{}, {})", context.jobId, currentStart, currentEnd);
} }
@Override @Override