From bae9870528bc7a5d3177af0d6f4286707ed24d4b Mon Sep 17 00:00:00 2001 From: nandan Date: Wed, 4 Sep 2024 19:55:30 +0000 Subject: [PATCH] Added a override function for finalizeSnapshot Signed-off-by: nandan --- .../repository/RemoteClusterRepository.kt | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) diff --git a/src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt b/src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt index 8ea986c7..45ca8e6f 100644 --- 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" @@ -116,12 +117,19 @@ class RemoteClusterRepository(private val repositoryMetadata: RepositoryMetadata } override fun finalizeSnapshot(shardGenerations: ShardGenerations?, repositoryStateId: Long, clusterMetadata: Metadata?, - snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?, - stateTransformer: Function?, - listener: ActionListener?) { - throw UnsupportedOperationException("Operation not permitted") + snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?, + stateTransformer: Function?, + listener: ActionListener?) { + throw UnsupportedOperationException("Operation not permitted") } + override fun finalizeSnapshot(shardGenerations: ShardGenerations?, repositoryStateId: Long, clusterMetadata: Metadata?, + snapshotInfo: SnapshotInfo?, repositoryMetaVersion: Version?, + stateTransformer: Function?, repositoryUpdatePriority: Priority, + listener: ActionListener?) { + throw UnsupportedOperationException("Operation not permitted") + } + override fun deleteSnapshots(snapshotIds: MutableCollection?, repositoryStateId: Long, repositoryMetaVersion: Version?, listener: ActionListener?) { throw UnsupportedOperationException("Operation not permitted")