From 83c916449f1635c4aabb750802d06353534f3049 Mon Sep 17 00:00:00 2001 From: Niels Bauman Date: Fri, 24 May 2024 08:55:08 +0200 Subject: [PATCH] Feedback --- .../action/admin/indices/rollover/LazyRolloverAction.java | 1 - .../admin/indices/rollover/TransportRolloverAction.java | 5 ----- 2 files changed, 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 index ec37a93bc5dcd..61e43ef9ab27f 100644 --- 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 { 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/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java b/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java index 433ba603e2cec..abf42cffdaa01 100644 --- a/server/src/main/java/org/elasticsearch/action/admin/indices/rollover/TransportRolloverAction.java +++ b/server/src/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()) {