23
23
import java .util .Collection ;
24
24
25
25
import static org .opensearch .common .xcontent .XContentFactory .jsonBuilder ;
26
+ import static org .opensearch .index .IndexSettings .MINIMUM_REFRESH_INTERVAL ;
26
27
import static org .opensearch .search .SearchService .CLUSTER_CONCURRENT_SEGMENT_SEARCH_SETTING ;
27
28
import static org .opensearch .search .aggregations .AggregationBuilders .terms ;
28
29
import static org .opensearch .test .OpenSearchIntegTestCase .Scope .TEST ;
@@ -71,7 +72,10 @@ public void testSimpleAggErrorMultiShard() throws Exception {
71
72
assertAcked (
72
73
prepareCreate ("idx_mshard_1" ).setMapping (STRING_FIELD_NAME , "type=keyword" )
73
74
.setSettings (
74
- Settings .builder ().put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 ).put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
75
+ Settings .builder ()
76
+ .put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 )
77
+ .put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
78
+ .put ("index.refresh_interval" , MINIMUM_REFRESH_INTERVAL )
75
79
)
76
80
);
77
81
client ().prepareIndex ("idx_mshard_1" ).setSource (jsonBuilder ().startObject ().field (STRING_FIELD_NAME , "A" ).endObject ()).get ();
@@ -89,7 +93,10 @@ public void testSimpleAggErrorMultiShard() throws Exception {
89
93
assertAcked (
90
94
prepareCreate ("idx_mshard_2" ).setMapping (STRING_FIELD_NAME , "type=keyword" )
91
95
.setSettings (
92
- Settings .builder ().put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 ).put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
96
+ Settings .builder ()
97
+ .put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 )
98
+ .put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
99
+ .put ("index.refresh_interval" , MINIMUM_REFRESH_INTERVAL )
93
100
)
94
101
);
95
102
client ().prepareIndex ("idx_mshard_2" ).setSource (jsonBuilder ().startObject ().field (STRING_FIELD_NAME , "A" ).endObject ()).get ();
@@ -127,7 +134,10 @@ public void testSimpleAggErrorSingleShard() throws Exception {
127
134
assertAcked (
128
135
prepareCreate ("idx_shard_error" ).setMapping (STRING_FIELD_NAME , "type=keyword" )
129
136
.setSettings (
130
- Settings .builder ().put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 ).put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
137
+ Settings .builder ()
138
+ .put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 )
139
+ .put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
140
+ .put ("index.refresh_interval" , MINIMUM_REFRESH_INTERVAL )
131
141
)
132
142
);
133
143
client ().prepareIndex ("idx_shard_error" ).setSource (jsonBuilder ().startObject ().field (STRING_FIELD_NAME , "A" ).endObject ()).get ();
@@ -170,7 +180,10 @@ public void testSliceLevelDocCountErrorSingleShard() throws Exception {
170
180
assertAcked (
171
181
prepareCreate ("idx_slice_error" ).setMapping (STRING_FIELD_NAME , "type=keyword" )
172
182
.setSettings (
173
- Settings .builder ().put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 ).put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
183
+ Settings .builder ()
184
+ .put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 )
185
+ .put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
186
+ .put ("index.refresh_interval" , MINIMUM_REFRESH_INTERVAL )
174
187
)
175
188
);
176
189
client ().prepareIndex ("idx_slice_error" ).setSource (jsonBuilder ().startObject ().field (STRING_FIELD_NAME , "A" ).endObject ()).get ();
@@ -248,7 +261,10 @@ public void testSliceLevelDocCountErrorMultiShard() throws Exception {
248
261
assertAcked (
249
262
prepareCreate ("idx_mshard_1" ).setMapping (STRING_FIELD_NAME , "type=keyword" )
250
263
.setSettings (
251
- Settings .builder ().put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 ).put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
264
+ Settings .builder ()
265
+ .put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 )
266
+ .put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
267
+ .put ("index.refresh_interval" , MINIMUM_REFRESH_INTERVAL )
252
268
)
253
269
);
254
270
client ().prepareIndex ("idx_mshard_1" ).setSource (jsonBuilder ().startObject ().field (STRING_FIELD_NAME , "A" ).endObject ()).get ();
@@ -288,7 +304,10 @@ public void testSliceLevelDocCountErrorMultiShard() throws Exception {
288
304
assertAcked (
289
305
prepareCreate ("idx_mshard_2" ).setMapping (STRING_FIELD_NAME , "type=keyword" )
290
306
.setSettings (
291
- Settings .builder ().put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 ).put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
307
+ Settings .builder ()
308
+ .put (IndexMetadata .SETTING_NUMBER_OF_SHARDS , 1 )
309
+ .put (IndexMetadata .SETTING_NUMBER_OF_REPLICAS , 0 )
310
+ .put ("index.refresh_interval" , MINIMUM_REFRESH_INTERVAL )
292
311
)
293
312
);
294
313
client ().prepareIndex ("idx_mshard_2" ).setSource (jsonBuilder ().startObject ().field (STRING_FIELD_NAME , "A" ).endObject ()).get ();
0 commit comments