@@ -78,7 +78,11 @@ public void testSettingPrecedence() {
7878 IndexSettings indexSettings = new IndexSettings (newIndexMeta ("test_index" , indexBuilder .build ()), nodeSettings );
7979 ShardId shardId = new ShardId ("test_index" , "test_uuid" , 0 );
8080
81- OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (shardId , indexSettings , new MergedSegmentTransferTracker ());
81+ OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (
82+ shardId ,
83+ indexSettings ,
84+ new MergedSegmentTransferTracker ()
85+ );
8286
8387 // Should use cluster-level setting
8488 assertThat (scheduler .getForceMergeMBPerSec (), equalTo (75.0 ));
@@ -105,7 +109,11 @@ public void testDisabledRateLimiting() {
105109 IndexSettings indexSettings = new IndexSettings (newIndexMeta ("test_index" , builder .build ()), Settings .EMPTY );
106110 ShardId shardId = new ShardId ("test_index" , "test_uuid" , 0 );
107111
108- OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (shardId , indexSettings , new MergedSegmentTransferTracker ());
112+ OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (
113+ shardId ,
114+ indexSettings ,
115+ new MergedSegmentTransferTracker ()
116+ );
109117
110118 // Should have no rate limiting
111119 assertThat (scheduler .getForceMergeMBPerSec (), equalTo (Double .POSITIVE_INFINITY ));
@@ -131,7 +139,11 @@ public void testDynamicRateLimitUpdates() throws Exception {
131139 IndexSettings indexSettings = new IndexSettings (newIndexMeta ("test_index" , builder .build ()), Settings .EMPTY );
132140 ShardId shardId = new ShardId ("test_index" , "test_uuid" , 0 );
133141
134- OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (shardId , indexSettings , new MergedSegmentTransferTracker ());
142+ OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (
143+ shardId ,
144+ indexSettings ,
145+ new MergedSegmentTransferTracker ()
146+ );
135147 assertThat (scheduler .getForceMergeMBPerSec (), equalTo (10.0 ));
136148
137149 // Update to a different rate limit
@@ -191,7 +203,11 @@ public void testFallbackToClusterSettingWhenIndexSettingRemoved() throws Excepti
191203 IndexSettings indexSettings = new IndexSettings (newIndexMeta ("test_index" , builder .build ()), nodeSettings );
192204 ShardId shardId = new ShardId ("test_index" , "test_uuid" , 0 );
193205
194- OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (shardId , indexSettings , new MergedSegmentTransferTracker ());
206+ OpenSearchConcurrentMergeScheduler scheduler = new OpenSearchConcurrentMergeScheduler (
207+ shardId ,
208+ indexSettings ,
209+ new MergedSegmentTransferTracker ()
210+ );
195211
196212 // Should initially use index-level setting
197213 assertThat (scheduler .getForceMergeMBPerSec (), equalTo (25.0 ));
0 commit comments