From e122adb71007a0b78b49ba14fec4a7baa0d665df Mon Sep 17 00:00:00 2001
From: Nicholas Walter Knize <nknize@apache.org>
Date: Fri, 7 Oct 2022 15:48:28 -0500
Subject: [PATCH] remove unnecessary legacy version check

Signed-off-by: Nicholas Walter Knize <nknize@apache.org>
---
 .../opensearch/indices/recovery/RecoverySourceHandler.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/server/src/main/java/org/opensearch/indices/recovery/RecoverySourceHandler.java b/server/src/main/java/org/opensearch/indices/recovery/RecoverySourceHandler.java
index 8c55a242d34f3..505d3c7adfb3f 100644
--- a/server/src/main/java/org/opensearch/indices/recovery/RecoverySourceHandler.java
+++ b/server/src/main/java/org/opensearch/indices/recovery/RecoverySourceHandler.java
@@ -40,7 +40,6 @@
 import org.apache.lucene.store.RateLimiter;
 import org.apache.lucene.util.ArrayUtil;
 import org.apache.lucene.util.SetOnce;
-import org.opensearch.LegacyESVersion;
 import org.opensearch.action.ActionListener;
 import org.opensearch.action.ActionRunnable;
 import org.opensearch.action.StepListener;
@@ -720,8 +719,7 @@ void createRetentionLease(final long startingSeqNo, ActionListener<RetentionLeas
                 // it's possible that the primary has no retention lease yet if we are doing a rolling upgrade from a version before
                 // 7.4, and in that case we just create a lease using the local checkpoint of the safe commit which we're using for
                 // recovery as a conservative estimate for the global checkpoint.
-                assert shard.indexSettings().getIndexVersionCreated().before(LegacyESVersion.fromId(7040099))
-                    || shard.indexSettings().isSoftDeleteEnabled() == false;
+                assert shard.indexSettings().isSoftDeleteEnabled() == false;
                 final StepListener<ReplicationResponse> addRetentionLeaseStep = new StepListener<>();
                 final long estimatedGlobalCheckpoint = startingSeqNo - 1;
                 final RetentionLease newLease = shard.addPeerRecoveryRetentionLease(