Skip to content

Commit 10873f1

Browse files
authored
Increase segrep pressure checkpoint default limit to 10 (opensearch-project#16577)
Signed-off-by: Gaurav Bafna <gbbafna@amazon.com>
1 parent e688388 commit 10873f1

File tree

3 files changed

+5
-1
lines changed

3 files changed

+5
-1
lines changed

CHANGELOG.md

+1
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
1111
- Add logic in master service to optimize performance and retain detailed logging for critical cluster operations. ([#14795](https://github.com/opensearch-project/OpenSearch/pull/14795))
1212
- Add Setting to adjust the primary constraint weights ([#16471](https://github.com/opensearch-project/OpenSearch/pull/16471))
1313
- Switch from `buildSrc/version.properties` to Gradle version catalog (`gradle/libs.versions.toml`) to enable dependabot to perform automated upgrades on common libs ([#16284](https://github.com/opensearch-project/OpenSearch/pull/16284))
14+
- Increase segrep pressure checkpoint default limit to 30 ([#16577](https://github.com/opensearch-project/OpenSearch/pull/16577/files))
1415
- Add dynamic setting allowing size > 0 requests to be cached in the request cache ([#16483](https://github.com/opensearch-project/OpenSearch/pull/16483))
1516
- Make IndexStoreListener a pluggable interface ([#16583](https://github.com/opensearch-project/OpenSearch/pull/16583))
1617

server/src/main/java/org/opensearch/index/SegmentReplicationPressureService.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public class SegmentReplicationPressureService implements Closeable {
6060

6161
public static final Setting<Integer> MAX_INDEXING_CHECKPOINTS = Setting.intSetting(
6262
"segrep.pressure.checkpoint.limit",
63-
4,
63+
30,
6464
1,
6565
Setting.Property.Dynamic,
6666
Setting.Property.NodeScope

server/src/test/java/org/opensearch/index/SegmentReplicationPressureServiceTests.java

+3
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import org.mockito.stubbing.Answer;
3434

3535
import static java.util.Arrays.asList;
36+
import static org.opensearch.index.SegmentReplicationPressureService.MAX_INDEXING_CHECKPOINTS;
3637
import static org.opensearch.index.SegmentReplicationPressureService.MAX_REPLICATION_LIMIT_STALE_REPLICA_SETTING;
3738
import static org.opensearch.index.SegmentReplicationPressureService.MAX_REPLICATION_TIME_BACKPRESSURE_SETTING;
3839
import static org.opensearch.index.SegmentReplicationPressureService.SEGMENT_REPLICATION_INDEXING_PRESSURE_ENABLED;
@@ -53,6 +54,7 @@ public class SegmentReplicationPressureServiceTests extends OpenSearchIndexLevel
5354
.put(IndexMetadata.SETTING_REPLICATION_TYPE, ReplicationType.SEGMENT)
5455
.put(SEGMENT_REPLICATION_INDEXING_PRESSURE_ENABLED.getKey(), true)
5556
.put(MAX_REPLICATION_TIME_BACKPRESSURE_SETTING.getKey(), TimeValue.timeValueSeconds(5))
57+
.put(MAX_INDEXING_CHECKPOINTS.getKey(), 4)
5658
.build();
5759

5860
public void testIsSegrepLimitBreached() throws Exception {
@@ -200,6 +202,7 @@ public void testFailStaleReplicaTask() throws Exception {
200202
.put(SEGMENT_REPLICATION_INDEXING_PRESSURE_ENABLED.getKey(), true)
201203
.put(MAX_REPLICATION_TIME_BACKPRESSURE_SETTING.getKey(), TimeValue.timeValueMillis(10))
202204
.put(MAX_REPLICATION_LIMIT_STALE_REPLICA_SETTING.getKey(), TimeValue.timeValueMillis(20))
205+
.put(MAX_INDEXING_CHECKPOINTS.getKey(), 4)
203206
.build();
204207

205208
try (ReplicationGroup shards = createGroup(1, settings, new NRTReplicationEngineFactory())) {

0 commit comments

Comments
 (0)