diff --git a/plugin/core/src/main/java/org/elasticsearch/license/XPackLicenseState.java b/plugin/core/src/main/java/org/elasticsearch/license/XPackLicenseState.java
index 7277998be1f..0c33005c02a 100644
--- a/plugin/core/src/main/java/org/elasticsearch/license/XPackLicenseState.java
+++ b/plugin/core/src/main/java/org/elasticsearch/license/XPackLicenseState.java
@@ -82,7 +82,6 @@ public class XPackLicenseState {
messages.put(XPackField.MACHINE_LEARNING, XPackLicenseState::machineLearningAcknowledgementMessages);
messages.put(XPackField.LOGSTASH, XPackLicenseState::logstashAcknowledgementMessages);
messages.put(XPackField.SQL, XPackLicenseState::sqlAcknowledgementMessages);
- messages.put(XPackField.ROLLUP, XPackLicenseState::rollupAcknowledgementMessages);
ACKNOWLEDGMENT_MESSAGES = Collections.unmodifiableMap(messages);
}
@@ -233,22 +232,6 @@ public class XPackLicenseState {
return Strings.EMPTY_ARRAY;
}
- private static String[] rollupAcknowledgementMessages(OperationMode currentMode, OperationMode newMode) {
- switch (newMode) {
- case BASIC:
- case STANDARD:
- case GOLD:
- switch (currentMode) {
- case TRIAL:
- case PLATINUM:
- return new String[] { "Creating new Rollup jobs or starting existing jobs will be disabled.",
- "All existing jobs can still be queried with GET APIs, and RollupSearch continues to function." };
- }
- break;
- }
- return Strings.EMPTY_ARRAY;
- }
-
/** A wrapper for the license mode and state, to allow atomically swapping. */
private static class Status {
@@ -499,26 +482,12 @@ public class XPackLicenseState {
}
/**
- * Determine if Rollup should be enabled.
- *
- * Rollup is only disabled when the license has expired or if the
- * mode is not:
- *
- * - {@link OperationMode#PLATINUM}
- * - {@link OperationMode#TRIAL}
- *
+ * Rollup is always available as long as there is a valid license
*
- * @return {@code true} as long as the license is valid. Otherwise
- * {@code false}.
+ * @return true if the license is active
*/
public boolean isRollupAllowed() {
- // status is volatile
- Status localStatus = status;
- OperationMode operationMode = localStatus.mode;
-
- boolean licensed = operationMode == OperationMode.TRIAL || operationMode == OperationMode.PLATINUM;
-
- return licensed && localStatus.active;
+ return status.active;
}
/**
diff --git a/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/action/TransportStopRollupAction.java b/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/action/TransportStopRollupAction.java
index 9257cc14659..2ae764c3c3a 100644
--- a/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/action/TransportStopRollupAction.java
+++ b/plugin/rollup/src/main/java/org/elasticsearch/xpack/rollup/action/TransportStopRollupAction.java
@@ -32,16 +32,14 @@ import java.util.function.Consumer;
public class TransportStopRollupAction extends TransportTasksAction {
- private final XPackLicenseState licenseState;
@Inject
public TransportStopRollupAction(Settings settings, TransportService transportService, ThreadPool threadPool,
ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver,
- ClusterService clusterService, XPackLicenseState licenseState) {
+ ClusterService clusterService) {
super(settings, StopRollupJobAction.NAME, threadPool, clusterService, transportService, actionFilters,
indexNameExpressionResolver, StopRollupJobAction.Request::new, StopRollupJobAction.Response::new, ThreadPool.Names.SAME);
- this.licenseState = licenseState;
}
@Override
@@ -51,12 +49,6 @@ public class TransportStopRollupAction extends TransportTasksAction listener) {
-
- if (!licenseState.isRollupAllowed()) {
- listener.onFailure(LicenseUtils.newComplianceException(XPackField.ROLLUP));
- return;
- }
-
super.doExecute(task, request, listener);
}