mirror of
https://github.com/honeymoose/OpenSearch.git
synced 2025-02-17 10:25:15 +00:00
Core: also log byte size and doc count when we log slow merges
Closes #8855 Closes #8853
This commit is contained in:
parent
127255f62e
commit
de75517357
@ -29,6 +29,7 @@ import org.elasticsearch.index.merge.OnGoingMerge;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.util.Collections;
|
||||
import java.util.Locale;
|
||||
import java.util.Set;
|
||||
|
||||
/**
|
||||
@ -117,10 +118,17 @@ public class TrackingConcurrentMergeScheduler extends ConcurrentMergeScheduler {
|
||||
totalMergesNumDocs.inc(totalNumDocs);
|
||||
totalMergesSizeInBytes.inc(totalSizeInBytes);
|
||||
totalMerges.inc(took);
|
||||
String message = String.format(Locale.ROOT,
|
||||
"merge segment %s done: took %s, %,.1f MB, %,d docs",
|
||||
merge.info == null ? "_na_" : merge.info.info.name,
|
||||
TimeValue.timeValueMillis(took),
|
||||
totalSizeInBytes/1024f/1024f,
|
||||
totalNumDocs);
|
||||
|
||||
if (took > 20000) { // if more than 20 seconds, DEBUG log it
|
||||
logger.debug("merge [{}] done, took [{}]", merge.info == null ? "_na_" : merge.info.info.name, TimeValue.timeValueMillis(took));
|
||||
logger.debug(message);
|
||||
} else if (logger.isTraceEnabled()) {
|
||||
logger.trace("merge [{}] done, took [{}]", merge.info == null ? "_na_" : merge.info.info.name, TimeValue.timeValueMillis(took));
|
||||
logger.trace(message);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user