Skip to content

Commit a5c2ba7

Browse files
Resetting log counter when attempt to log for repeated messages
1 parent d8ef7b4 commit a5c2ba7

File tree

1 file changed

+3
-0
lines changed
  • x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/logging

1 file changed

+3
-0
lines changed

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/logging/Throttler.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,9 @@ void logRepeatedMessages() {
149149
synchronized (skippedLogCalls) {
150150
numSkippedLogCalls = skippedLogCalls.get();
151151
if (hasRepeatedLogsToEmit(numSkippedLogCalls) == false) {
152+
// Since we tried to log but there were no repeated messages we'll reset this entry so a new message
153+
// would get logged like it is the first time
154+
skippedLogCalls.set(INITIAL_LOG_COUNTER_VALUE);
152155
return;
153156
}
154157
}

0 commit comments

Comments
 (0)