Always send coordination metadata in diff

Signed-off-by: Sooraj Sinha <[email protected]>
opensearch-project · Oct 7, 2024 · 8798069 · 8798069
1 parent 146b0f7
commit 8798069
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/server/src/main/java/org/opensearch/gateway/remote/ClusterStateDiffManifest.java b/server/src/main/java/org/opensearch/gateway/remote/ClusterStateDiffManifest.java
@@ -89,7 +89,7 @@ public ClusterStateDiffManifest(
     ) {
         fromStateUUID = previousState.stateUUID();
         toStateUUID = state.stateUUID();
-        coordinationMetadataUpdated = !Metadata.isCoordinationMetadataEqual(state.metadata(), previousState.metadata());
+        coordinationMetadataUpdated = true;
         settingsMetadataUpdated = !Metadata.isSettingsMetadataEqual(state.metadata(), previousState.metadata());
         transientSettingsMetadataUpdated = !Metadata.isTransientSettingsMetadataEqual(state.metadata(), previousState.metadata());
         templatesMetadataUpdated = !Metadata.isTemplatesMetadataEqual(state.metadata(), previousState.metadata());

diff --git a/server/src/test/java/org/opensearch/gateway/remote/model/ClusterStateDiffManifestTests.java b/server/src/test/java/org/opensearch/gateway/remote/model/ClusterStateDiffManifestTests.java
@@ -298,7 +298,7 @@ private ClusterStateDiffManifest updateAndVerifyState(
         assertEquals(customsToRemove, manifest.getCustomMetadataDeleted());
         assertEquals(new ArrayList<>(clusterStateCustomsToAdd.keySet()), manifest.getClusterStateCustomUpdated());
         assertEquals(clusterStateCustomsToRemove, manifest.getClusterStateCustomDeleted());
-        assertEquals(updateCoordinationState, manifest.isCoordinationMetadataUpdated());
+        assertTrue(manifest.isCoordinationMetadataUpdated());
         assertEquals(updatePersistentSettings, manifest.isSettingsMetadataUpdated());
         assertEquals(updateTemplates, manifest.isTemplatesMetadataUpdated());
         assertEquals(updateTransientSettings, manifest.isTransientSettingsMetadataUpdated());