diff --git a/server/src/main/java/org/opensearch/action/support/clustermanager/ClusterManagerNodeAckRequest.java b/server/src/main/java/org/opensearch/action/support/clustermanager/ClusterManagerNodeAckRequest.java index ab0bf7b69e290..d050707df8fe2 100644 --- a/server/src/main/java/org/opensearch/action/support/clustermanager/ClusterManagerNodeAckRequest.java +++ b/server/src/main/java/org/opensearch/action/support/clustermanager/ClusterManagerNodeAckRequest.java @@ -11,11 +11,11 @@ import org.opensearch.common.unit.TimeValue; import org.opensearch.core.common.io.stream.StreamInput; import org.opensearch.core.common.io.stream.StreamOutput; -import static org.opensearch.common.unit.TimeValue.timeValueSeconds; - import java.io.IOException; +import static org.opensearch.common.unit.TimeValue.timeValueSeconds; + /** * A base request for cluster-manager based operations. * It is similar to ClusterManagerNodeRequest, but extends ActionRequest and AckedRequest. @@ -74,6 +74,7 @@ public final TimeValue masterNodeTimeout() { public ActionRequestValidationException validate() { return null; } + @Override public TimeValue ackTimeout() { return this.timeout; diff --git a/server/src/main/java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeExtendedAction.java b/server/src/main/java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeExtendedAction.java index 20b1b56b99afc..5cf0485a6fc5d 100644 --- a/server/src/main/java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeExtendedAction.java +++ b/server/src/main/java/org/opensearch/action/support/clustermanager/TransportClusterManagerNodeExtendedAction.java @@ -4,6 +4,7 @@ */ package org.opensearch.action.support.clustermanager; + import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.message.ParameterizedMessage; @@ -57,8 +58,9 @@ * It is similar to TransportClusterManagerNodeAction, but the difference is in the generic type of the Request parameter expecting it to be a subclass of ClusterManagerNodeAckRequest. * @opensearch.internal */ -public abstract class TransportClusterManagerNodeExtendedAction - extends HandledTransportAction { +public abstract class TransportClusterManagerNodeExtendedAction< + Request extends ClusterManagerNodeAckRequest, + Response extends ActionResponse> extends HandledTransportAction { private static final Logger logger = LogManager.getLogger(TransportClusterManagerNodeExtendedAction.class);