Feedback

nielsbauman · May 24, 2024 · 83c9164 · 83c9164
1 parent 3093ea4
commit 83c9164
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/LazyRolloverAction.java b/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/LazyRolloverAction.java
@@ -35,7 +35,6 @@
 public final class LazyRolloverAction extends ActionType<RolloverResponse> {
 
     public static final NodeFeature DATA_STREAM_LAZY_ROLLOVER = new NodeFeature("data_stream.rollover.lazy");
-    public static final NodeFeature FAILURE_STORE_LAZY_ROLLOVER = new NodeFeature("data_stream.rollover.lazy.failure_store");
 
     public static final LazyRolloverAction INSTANCE = new LazyRolloverAction();
     public static final String NAME = "indices:admin/data_stream/lazy_rollover";

diff --git a/...rc/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java b/...rc/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java
@@ -181,11 +181,6 @@ protected void masterOperation(
         final String trialRolloverIndexName = trialRolloverNames.rolloverName();
         MetadataRolloverService.validateIndexName(clusterState, trialRolloverIndexName);
 
-        if (rolloverRequest.isLazy() && targetFailureStore && DataStream.isFailureStoreFeatureFlagEnabled() == false) {
-            listener.onFailure(new IllegalArgumentException("Not all nodes in this cluster support lazily rolling over a failure store"));
-            return;
-        }
-
         boolean isDataStream = metadata.dataStreams().containsKey(rolloverRequest.getRolloverTarget());
         if (rolloverRequest.isLazy()) {
             if (isDataStream == false || rolloverRequest.getConditions().hasConditions()) {