@@ -11,6 +11,7 @@ import org.opensearch.action.bulk.BackoffPolicy
1111import org.opensearch.common.settings.Settings
1212import org.opensearch.common.unit.TimeValue
1313import org.opensearch.commons.ConfigConstants
14+ import org.opensearch.index.engine.VersionConflictEngineException
1415import org.opensearch.indexmanagement.IndexManagementIndices
1516import org.opensearch.indexmanagement.opensearchapi.IndexManagementSecurityContext
1617import org.opensearch.indexmanagement.opensearchapi.retry
@@ -122,8 +123,12 @@ class SMStateMachine(
122123 }
123124 } while (currentState.instance.continuous && result is SMResult .Next )
124125 } catch (ex: Exception ) {
125- val message = " There was an exception at ${now()} while executing Snapshot Management policy ${job.policyName} , please check logs."
126- job.notificationConfig?.sendFailureNotification(client, job.policyName, message, job.user, log)
126+ @Suppress(" InstanceOfCheckForException" )
127+ if (ex !is VersionConflictEngineException ) {
128+ val message = " There was an exception at ${now()} while executing Snapshot Management policy ${job.policyName} , please check logs."
129+ job.notificationConfig?.sendFailureNotification(client, job.policyName, message, job.user, log)
130+ }
131+
127132 @Suppress(" InstanceOfCheckForException" )
128133 if (ex is SnapshotManagementException &&
129134 ex.exKey == ExceptionKey .METADATA_INDEXING_FAILURE
0 commit comments