Skip to content

Commit 6215f03

Browse files
committed
Check setting in tests
1 parent 7f7372a commit 6215f03

File tree

1 file changed

+5
-4
lines changed
  • server/src/internalClusterTest/java/org/elasticsearch/index/store

1 file changed

+5
-4
lines changed

server/src/internalClusterTest/java/org/elasticsearch/index/store/DirectIOIT.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ protected Collection<Class<? extends Plugin>> nodePlugins() {
7272
}
7373

7474
private void indexVectors() {
75-
String type = randomFrom(/*"bbq_flat", */"bbq_hnsw");
75+
String type = "bbq_hnsw";
7676
assertAcked(
7777
prepareCreate("foo-vectors").setSettings(Settings.builder().put(InternalSettingsPlugin.USE_COMPOUND_FILE.getKey(), false))
7878
.setMapping("""
@@ -102,11 +102,12 @@ private void indexVectors() {
102102
assertBBQIndexType(type); // test assertion to ensure that the correct index type is being used
103103
}
104104

105-
@SuppressWarnings("unchecked")
106105
static void assertBBQIndexType(String type) {
107106
var response = indicesAdmin().prepareGetFieldMappings("foo-vectors").setFields("fooVector").get();
108-
var map = (Map<String, Object>) response.fieldMappings("foo-vectors", "fooVector").sourceAsMap().get("fooVector");
109-
assertThat((String) ((Map<String, Object>) map.get("index_options")).get("type"), is(equalTo(type)));
107+
var map = (Map<?, ?>) response.fieldMappings("foo-vectors", "fooVector").sourceAsMap().get("fooVector");
108+
var options = (Map<?, ?>) map.get("index_options");
109+
assertThat(options.get("type"), is(equalTo(type)));
110+
assertThat(options.get("disable_offheap_cache_rescoring"), is(true));
110111
}
111112

112113
@TestLogging(value = "org.elasticsearch.index.store.FsDirectoryFactory:DEBUG", reason = "to capture trace logging for direct IO")

0 commit comments

Comments
 (0)