honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix AbstractSearchableSnapshotsRestTestCase.testClearCache (#58847) 

Since #58728 part of searchable snapshot shard files are written in cache 
in an asynchronous manner in a dedicated thread pool. It means that even 
if a search query is successful and returns, there are still more bytes to 
write in the cached files on disk.

On CI this can be slow; if we want to check that the cached_bytes_written 
has changed we need to check multiple times to give some time for the 
cached data to be effectively written.
This commit is contained in:
Tanguy Leroux 2020-07-01 17:52:08 +02:00
parent c768467155
commit ec4843f4df
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
x-pack/plugin/searchable-snapshots/src/test/java/org/elasticsearch/xpack/searchablesnapshots/AbstractSearchableSnapshotsRestTestCase.java
View File

@ -203,8 +203,10 @@ public abstract class AbstractSearchableSnapshotsRestTestCase extends ESRestTest
searchResults = search(restoredIndexName, QueryBuilders.matchAllQuery(), Boolean.TRUE); searchResults = search(restoredIndexName, QueryBuilders.matchAllQuery(), Boolean.TRUE);
assertThat(extractValue(searchResults, "hits.total.value"), equalTo(numDocs)); assertThat(extractValue(searchResults, "hits.total.value"), equalTo(numDocs));
final long bytesInCacheAfterSearch = sumCachedBytesWritten.apply(searchableSnapshotStats(restoredIndexName)); assertBusy(() -> {
assertThat(bytesInCacheAfterSearch, greaterThan(bytesInCacheBeforeClear)); final long bytesInCacheAfterSearch = sumCachedBytesWritten.apply(searchableSnapshotStats(restoredIndexName));
assertThat(bytesInCacheAfterSearch, greaterThan(bytesInCacheBeforeClear));
});
}); });
} }
@ -419,6 +421,6 @@ public abstract class AbstractSearchableSnapshotsRestTestCase extends ESRestTest
*/ */
@FunctionalInterface @FunctionalInterface
interface SearchableSnapshotsTestCaseBody { interface SearchableSnapshotsTestCaseBody {
void runTest(String indexName, int numDocs) throws IOException; void runTest(String indexName, int numDocs) throws Exception;
} }
} }