diff --git a/server/src/main/java/org/opensearch/extensions/UpdateSettingsResponseHandler.java b/server/src/main/java/org/opensearch/extensions/UpdateSettingsResponseHandler.java index be8f43b5cfce6..9bf53812c223e 100644 --- a/server/src/main/java/org/opensearch/extensions/UpdateSettingsResponseHandler.java +++ b/server/src/main/java/org/opensearch/extensions/UpdateSettingsResponseHandler.java @@ -33,6 +33,9 @@ public AcknowledgedResponse read(StreamInput in) throws IOException { @Override public void handleResponse(AcknowledgedResponse response) { logger.info("response {}", response.getStatus()); + if (!response.getStatus()) { + handleException(new TransportException("Request was not completed successfully")); + } } @Override