Addressing comments

Signed-off-by: Shourya Dutta Biswas <[email protected]>
shourya035 · Jul 18, 2024 · f637670 · f637670
1 parent d39227b
commit f637670
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...er/src/internalClusterTest/java/org/opensearch/remotemigration/MigrationBaseTestCase.java b/...er/src/internalClusterTest/java/org/opensearch/remotemigration/MigrationBaseTestCase.java
@@ -297,8 +297,8 @@ public void completeDocRepToRemoteMigration() {
                 .prepareUpdateSettings()
                 .setPersistentSettings(
                     Settings.builder()
-                        .put(REMOTE_STORE_COMPATIBILITY_MODE_SETTING.getKey(), "strict")
-                        .put(MIGRATION_DIRECTION_SETTING.getKey(), "none")
+                        .putNull(REMOTE_STORE_COMPATIBILITY_MODE_SETTING.getKey())
+                        .putNull(MIGRATION_DIRECTION_SETTING.getKey())
                 )
                 .get()
                 .isAcknowledged()

diff --git a/...va/org/opensearch/action/admin/cluster/settings/TransportClusterUpdateSettingsAction.java b/...va/org/opensearch/action/admin/cluster/settings/TransportClusterUpdateSettingsAction.java
@@ -285,7 +285,7 @@ public ClusterState execute(final ClusterState currentState) {
                      flow. That way we are not interfering with the usual settings update
                      and the cluster state mutation that comes along with it
                     */
-                    if (isCompatibilityModeChanging == true && isSwitchToStrictCompatibilityMode(request) == true) {
+                    if (isCompatibilityModeChanging && isSwitchToStrictCompatibilityMode(request)) {
                         ClusterState newStateAfterIndexMdChanges = finalizeMigration(clusterState);
                         changed = newStateAfterIndexMdChanges != currentState;
                         return newStateAfterIndexMdChanges;