From d15ded5728069bf6d1d1599a174b1686a4ca43bf Mon Sep 17 00:00:00 2001 From: Varun Bansal Date: Mon, 20 May 2024 12:41:19 +0530 Subject: [PATCH] introduce a new exception for segment upload failures and handle interrupted latch.await Signed-off-by: Varun Bansal --- .../shard/RemoteStoreRefreshListener.java | 2 +- .../shard/SegmentUploadFailedException.java | 18 ++++++++++++++++++ 2 files changed, 19 insertions(+), 1 deletion(-) create mode 100644 server/src/main/java/org/opensearch/index/shard/SegmentUploadFailedException.java diff --git a/server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java b/server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java index 3a411b2cec189..20afd7b2f3568 100644 --- a/server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java +++ b/server/src/main/java/org/opensearch/index/shard/RemoteStoreRefreshListener.java @@ -295,7 +295,7 @@ public void onFailure(Exception e) { remoteStoreSettings.getClusterRemoteSegmentTransferTimeout().millis(), TimeUnit.MILLISECONDS ) == false) { - throw new InterruptedException("Timeout while waiting for remote segment transfer to complete"); + throw new SegmentUploadFailedException("Timeout while waiting for remote segment transfer to complete"); } } catch (EngineException e) { logger.warn("Exception while reading SegmentInfosSnapshot", e); diff --git a/server/src/main/java/org/opensearch/index/shard/SegmentUploadFailedException.java b/server/src/main/java/org/opensearch/index/shard/SegmentUploadFailedException.java new file mode 100644 index 0000000000000..ecd7313ad0db6 --- /dev/null +++ b/server/src/main/java/org/opensearch/index/shard/SegmentUploadFailedException.java @@ -0,0 +1,18 @@ +/* + * SPDX-License-Identifier: Apache-2.0 + * + * The OpenSearch Contributors require contributions made to + * this file be licensed under the Apache-2.0 license or a + * compatible open source license. + */ + +package org.opensearch.index.shard; + +import java.io.IOException; + +public class SegmentUploadFailedException extends IOException { + + public SegmentUploadFailedException(String message) { + super(message); + } +}