Backported 1438 to 2.17 (#1440)

* Added a override function for finalizeSnapshot Signed-off-by: nandan <nandnkum@amazon.com> * Added release note for 2.17.0 Signed-off-by: nandan <nandnkum@amazon.com> * Fixing Identation Signed-off-by: nandan <nandnkum@amazon.com> --------- Signed-off-by: nandan <nandnkum@amazon.com>
opensearch-project · Sep 5, 2024 · 0ebea49 · 0ebea49
1 parent 5310ffc
commit 0ebea49
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/release-notes/opensearch-cross-cluster-replication.release-notes-2.17.0.0.md b/release-notes/opensearch-cross-cluster-replication.release-notes-2.17.0.0.md
@@ -0,0 +1,6 @@
+## Version 2.17.0.0 Release Notes
+
+Compatible with OpenSearch 2.17.0
+
+### Bug Fixes
+* Updating remote-migration IT with correct setting name ([#1412](https://github.com/opensearch-project/cross-cluster-replication/pull/1412))
diff --git a/src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt b/src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt
@@ -74,6 +74,7 @@ import java.util.UUID
 import java.util.function.Consumer
 import java.util.function.Function
 import kotlin.collections.ArrayList
+import org.opensearch.common.Priority
 
 const val REMOTE_REPOSITORY_PREFIX = "replication-remote-repo-"
 const val REMOTE_REPOSITORY_TYPE = "replication-remote-repository"
@@ -122,6 +123,13 @@ class RemoteClusterRepository(private val repositoryMetadata: RepositoryMetadata
         throw UnsupportedOperationException("Operation not permitted")
     }
 
+    override fun finalizeSnapshot(shardGenerations: ShardGenerations?, repositoryStateId: Long, clusterMetadata: Metadata?,
+                                  snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?,
+                                  stateTransformer: Function<ClusterState, ClusterState>?, repositoryUpdatePriority: Priority,
+                                  listener: ActionListener<RepositoryData>?) {
+        throw UnsupportedOperationException("Operation not permitted")
+    }
+
     override fun deleteSnapshots(snapshotIds: MutableCollection<SnapshotId>?, repositoryStateId: Long,
                                  repositoryMetaVersion: Version?, listener: ActionListener<RepositoryData>?) {
         throw UnsupportedOperationException("Operation not permitted")