Revert tidy-up for safer backporting

elastic · Dec 12, 2022 · 768a864 · 768a864
1 parent c95a33e
commit 768a864
Showing 1 changed file with 19 additions and 10 deletions.
diff --git a/server/src/main/java/org/elasticsearch/cluster/coordination/CoordinationState.java b/server/src/main/java/org/elasticsearch/cluster/coordination/CoordinationState.java
@@ -556,18 +556,27 @@ public interface PersistedState extends Closeable {
          * marked as committed.
          */
         default void markLastAcceptedStateAsCommitted() {
-            final var lastAcceptedState = getLastAcceptedState();
-            final var hasClusterUuid = lastAcceptedState.metadata().clusterUUID().equals(Metadata.UNKNOWN_CLUSTER_UUID) == false;
-            assert hasClusterUuid : "received cluster state with empty cluster uuid: " + lastAcceptedState;
-
-            if (hasClusterUuid && lastAcceptedState.metadata().clusterUUIDCommitted() == false) {
+            final ClusterState lastAcceptedState = getLastAcceptedState();
+            Metadata.Builder metadataBuilder = null;
+            if (lastAcceptedState.getLastAcceptedConfiguration().equals(lastAcceptedState.getLastCommittedConfiguration()) == false) {
+                final CoordinationMetadata coordinationMetadata = CoordinationMetadata.builder(lastAcceptedState.coordinationMetadata())
+                    .lastCommittedConfiguration(lastAcceptedState.getLastAcceptedConfiguration())
+                    .build();
+                metadataBuilder = Metadata.builder(lastAcceptedState.metadata());
+                metadataBuilder.coordinationMetadata(coordinationMetadata);
+            }
+            assert lastAcceptedState.metadata().clusterUUID().equals(Metadata.UNKNOWN_CLUSTER_UUID) == false
+                : "received cluster state with empty cluster uuid: " + lastAcceptedState;
+            if (lastAcceptedState.metadata().clusterUUID().equals(Metadata.UNKNOWN_CLUSTER_UUID) == false
+                && lastAcceptedState.metadata().clusterUUIDCommitted() == false) {
+                if (metadataBuilder == null) {
+                    metadataBuilder = Metadata.builder(lastAcceptedState.metadata());
+                }
+                metadataBuilder.clusterUUIDCommitted(true);
                 logger.info("cluster UUID set to [{}]", lastAcceptedState.metadata().clusterUUID());
             }
-
-            final var adjustedMetadata = lastAcceptedState.metadata()
-                .withLastCommittedValues(hasClusterUuid, lastAcceptedState.getLastAcceptedConfiguration());
-            if (adjustedMetadata != lastAcceptedState.metadata()) {
-                setLastAcceptedState(ClusterState.builder(lastAcceptedState).metadata(adjustedMetadata).build());
+            if (metadataBuilder != null) {
+                setLastAcceptedState(ClusterState.builder(lastAcceptedState).metadata(metadataBuilder).build());
             }
         }