Core: do not throttle recovery indexing operations when replaying tra…

…nsaction log

Closes elastic#9396

Closes elastic#9394

src/main/java/org/elasticsearch/index/engine/internal/InternalEngine.java

@@ -400,8 +400,13 @@ public void create(Create create) throws EngineException {
         final IndexWriter writer;
         try (InternalLock _ = readLock.acquire()) {
             writer = currentIndexWriter();
-            try (Releasable r = throttle.acquireThrottle()) {
+            if (create.origin() == Operation.Origin.RECOVERY) {
+                // Don't throttle recovery operations
                 innerCreate(create, writer);
+            } else {
+                try (Releasable r = throttle.acquireThrottle()) {
+                    innerCreate(create, writer);
+                }
             }
             dirty = true;
             possibleMergeNeeded = true;
@@ -413,7 +418,6 @@ public void create(Create create) throws EngineException {
         checkVersionMapRefresh();
     }
 
-
     private void innerCreate(Create create, IndexWriter writer) throws IOException {
         if (optimizeAutoGenerateId && create.autoGeneratedId() && !create.canHaveDuplicates()) {
             // We don't need to lock because this ID cannot be concurrently updated:
@@ -505,8 +509,13 @@ public void index(Index index) throws EngineException {
         final IndexWriter writer;
         try (InternalLock _ = readLock.acquire()) {
             writer = currentIndexWriter();
-            try (Releasable r = throttle.acquireThrottle()) {
+            if (index.origin() == Operation.Origin.RECOVERY) {
+                // Don't throttle recovery operations
                 innerIndex(index, writer);
+            } else {
+                try (Releasable r = throttle.acquireThrottle()) {
+                    innerIndex(index, writer);
+                }
             }
             dirty = true;
             possibleMergeNeeded = true;