try to fix opensearch-project#3962 catching exception

draios · Jul 25, 2022 · dc1a00a · dc1a00a
1 parent c0a5b6b
commit dc1a00a
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/server/src/main/java/org/opensearch/action/search/AbstractSearchAsyncAction.java b/server/src/main/java/org/opensearch/action/search/AbstractSearchAsyncAction.java
@@ -460,10 +460,7 @@ private void onShardFailure(final int shardIndex, @Nullable SearchShardTarget sh
                 onPhaseFailure(this, "The phase has failed", ex);
             }
         } else if (totalOps > expectedTotalOps) {
-            throw new AssertionError(
-                "unexpected higher total ops [" + totalOps + "] compared to expected [" + expectedTotalOps + "]",
-                new SearchPhaseExecutionException(getName(), "Shard failures", null, buildShardFailures())
-            );
+            onPhaseFailure(this, "The phase has failed: unexpected higher total ops [" + totalOps + "] compared to expected [" + expectedTotalOps + "]", null);
         } else {
             if (lastShard == false) {
                 performPhaseOnShard(shardIndex, shardIt, nextShard);