diff --git a/RFS/src/main/java/com/rfs/common/OpenSearchClient.java b/RFS/src/main/java/com/rfs/common/OpenSearchClient.java index cc8e5b5af..b596ca54f 100644 --- a/RFS/src/main/java/com/rfs/common/OpenSearchClient.java +++ b/RFS/src/main/java/com/rfs/common/OpenSearchClient.java @@ -141,7 +141,7 @@ private Optional createObjectIdempotent( .retryWhen( Retry.backoff(3, Duration.ofSeconds(1)) .maxBackoff(Duration.ofSeconds(10)) - .filter(OperationFailed.class::isInstance) + .filter(throwable -> !(throwable instanceof InvalidResponse)) // Do not retry on this exception ) .block();