Skip to content

Commit 55e8cef

Browse files
committed
Reduce cluster state persistence check frequency (#84517)
In #84142 we introduced a somewhat-expensive assertion that every cluster state we write can be read again. In practice we don't need to check that property every time, so with this commit we usually skip it.
1 parent fc3dee1 commit 55e8cef

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

server/src/main/java/org/elasticsearch/gateway/PersistedClusterStateService.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
import org.elasticsearch.cluster.metadata.IndexMetadata;
4646
import org.elasticsearch.cluster.metadata.Metadata;
4747
import org.elasticsearch.common.CheckedBiConsumer;
48+
import org.elasticsearch.common.Randomness;
4849
import org.elasticsearch.common.bytes.BytesArray;
4950
import org.elasticsearch.common.bytes.BytesReference;
5051
import org.elasticsearch.common.bytes.CompositeBytesReference;
@@ -1008,7 +1009,7 @@ void commit(long currentTerm, long lastAcceptedVersion, Version oldestIndexVersi
10081009
}
10091010

10101011
private boolean assertOnCommit() {
1011-
if (assertOnCommit != null /* TODO && Randomness.get().nextInt(100) == 0 */) {
1012+
if (assertOnCommit != null && Randomness.get().nextInt(100) == 0) {
10121013
// only rarely run this assertion since reloading the whole state can be quite expensive
10131014
for (final var metadataIndexWriter : metadataIndexWriters) {
10141015
try (var directoryReader = DirectoryReader.open(metadataIndexWriter.indexWriter)) {

0 commit comments

Comments
 (0)