Remove unnecessary error check

carlosdelest · Jan 18, 2024 · ed6a514 · ed6a514
1 parent 3e5e3d2
commit ed6a514
Showing 1 changed file with 0 additions and 6 deletions.
diff --git a/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java b/server/src/main/java/org/elasticsearch/action/bulk/TransportBulkAction.java
@@ -743,12 +743,6 @@ private void executeBulkRequestsByShard(Map<ShardId, List<BulkItemRequest>> requ
         }
 
         private void executeBulkShardRequest(BulkShardRequest bulkShardRequest, Releasable releaseOnFinish) {
-            if (bulkShardRequest.items().length == 0) {
-                // No requests to execute due to previous errors, terminate early
-                releaseOnFinish.close();
-                return;
-            }
-
             client.executeLocally(TransportShardBulkAction.TYPE, bulkShardRequest, new ActionListener<>() {
                 @Override
                 public void onResponse(BulkShardResponse bulkShardResponse) {