Skip to content

Commit 972b1bd

Browse files
author
Harsh Kothari
committed
Added PR link to CHANGELOG, added tracker safety check in hasWarmNodes logic
Signed-off-by: Harsh Kothari <[email protected]>
1 parent 34ba425 commit 972b1bd

File tree

4 files changed

+8
-7
lines changed

4 files changed

+8
-7
lines changed

CHANGELOG.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
4646
- Fix the visit of sub queries for HasParentQuery and HasChildQuery ([#18621](https://github.com/opensearch-project/OpenSearch/pull/18621))
4747
- Fix the backward compatibility regression with COMPLEMENT for Regexp queries introduced in OpenSearch 3.0 ([#18640](https://github.com/opensearch-project/OpenSearch/pull/18640))
4848
- Fix Replication lag computation ([#18602](https://github.com/opensearch-project/OpenSearch/pull/18602))
49-
- Fixed Staggered merge - load average replace with AverageTrackers, some Default thresholds modified
49+
- Fixed Staggered merge - load average replace with AverageTrackers, some Default thresholds modified ([#18666](https://github.com/opensearch-project/OpenSearch/pull/18666))
5050

5151
### Security
5252

server/src/main/java/org/opensearch/index/autoforcemerge/AutoForceMergeManager.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,7 @@ private void triggerForceMerge() {
127127

128128
private boolean isValidForForceMerge() {
129129
if (configurationValidator.hasWarmNodes() == false) {
130+
resourceTrackers.stop();
130131
logger.debug("No warm nodes found. Skipping Auto Force merge.");
131132
return false;
132133
}

server/src/main/java/org/opensearch/index/autoforcemerge/ResourceTrackerProvider.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@
2020
*/
2121
public class ResourceTrackerProvider {
2222

23-
public static final TimeValue AVERAGE_WINDOW_ONE_SECOND = TimeValue.timeValueSeconds(1);
24-
public static final TimeValue AVERAGE_WINDOW_FIVE_SECOND = TimeValue.timeValueSeconds(5);
23+
public static final TimeValue AVERAGE_WINDOW_ONE_SECOND = TimeValue.timeValueSeconds(6);
24+
public static final TimeValue AVERAGE_WINDOW_FIVE_SECOND = TimeValue.timeValueSeconds(30);
2525
public static final TimeValue AVERAGE_WINDOW_ONE_MINUTE = TimeValue.timeValueMinutes(1);
2626
public static final TimeValue AVERAGE_WINDOW_FIVE_MINUTE = TimeValue.timeValueMinutes(5);
2727

server/src/test/java/org/opensearch/index/autoforcemerge/AutoForceMergeManagerTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -237,10 +237,10 @@ public void testNodeValidatorWithHighCPU() {
237237
autoForceMergeManager.start();
238238
when(cpu.getPercent()).thenReturn((short) 95);
239239
assertFalse(autoForceMergeManager.getNodeValidator().validate().isAllowed());
240-
for (int i = 0; i < 60; i++)
240+
for (int i = 0; i < 10; i++)
241241
ResourceTrackerProvider.resourceTrackers.cpuOneMinute.recordUsage(90);
242242
assertFalse(autoForceMergeManager.getNodeValidator().validate().isAllowed());
243-
for (int i = 0; i < 60; i++)
243+
for (int i = 0; i < 10; i++)
244244
ResourceTrackerProvider.resourceTrackers.cpuFiveMinute.recordUsage(90);
245245
assertFalse(autoForceMergeManager.getNodeValidator().validate().isAllowed());
246246
autoForceMergeManager.close();
@@ -261,10 +261,10 @@ public void testNodeValidatorWithHighJVMUsage() {
261261
autoForceMergeManager.start();
262262
when(jvm.getHeapUsedPercent()).thenReturn((short) 90);
263263
assertFalse(autoForceMergeManager.getNodeValidator().validate().isAllowed());
264-
for(int i = 0; i < 60; i++)
264+
for(int i = 0; i < 10; i++)
265265
ResourceTrackerProvider.resourceTrackers.jvmOneMinute.recordUsage(90);
266266
assertFalse(autoForceMergeManager.getNodeValidator().validate().isAllowed());
267-
for(int i = 0; i < 60; i++)
267+
for(int i = 0; i < 10; i++)
268268
ResourceTrackerProvider.resourceTrackers.jvmFiveMinute.recordUsage(90);
269269
assertFalse(autoForceMergeManager.getNodeValidator().validate().isAllowed());
270270
autoForceMergeManager.close();

0 commit comments

Comments
 (0)