|
@@ -11,8 +11,6 @@ package org.elasticsearch.rest.action.admin.cluster;
|
|
|
import org.elasticsearch.action.admin.cluster.settings.ClusterUpdateSettingsRequest;
|
|
|
import org.elasticsearch.client.Requests;
|
|
|
import org.elasticsearch.client.node.NodeClient;
|
|
|
-import org.elasticsearch.common.logging.DeprecationCategory;
|
|
|
-import org.elasticsearch.common.logging.DeprecationLogger;
|
|
|
import org.elasticsearch.common.settings.Settings;
|
|
|
import org.elasticsearch.rest.BaseRestHandler;
|
|
|
import org.elasticsearch.rest.RestRequest;
|
|
@@ -27,10 +25,6 @@ import java.util.Set;
|
|
|
import static org.elasticsearch.rest.RestRequest.Method.PUT;
|
|
|
|
|
|
public class RestClusterUpdateSettingsAction extends BaseRestHandler {
|
|
|
- private static final DeprecationLogger deprecationLogger = DeprecationLogger.getLogger(RestClusterUpdateSettingsAction.class);
|
|
|
- static final String TRANSIENT_SETTINGS_DEPRECATION_MESSAGE = "[transient settings removal]"
|
|
|
- + " Updating cluster settings through transientSettings is deprecated. Use persistent settings instead.";
|
|
|
-
|
|
|
private static final String PERSISTENT = "persistent";
|
|
|
private static final String TRANSIENT = "transient";
|
|
|
|
|
@@ -57,15 +51,7 @@ public class RestClusterUpdateSettingsAction extends BaseRestHandler {
|
|
|
source = parser.map();
|
|
|
}
|
|
|
if (source.containsKey(TRANSIENT)) {
|
|
|
- Map<String, ?> transientSettings = (Map<String, ?>) source.get(TRANSIENT);
|
|
|
-
|
|
|
- // We check for empty transient settings map because ClusterUpdateSettingsRequest initializes
|
|
|
- // each of the settings to an empty collection. When the RestClient is used, we'll get an empty
|
|
|
- // transient settings map, even if we never set any transient settings.
|
|
|
- if (transientSettings.isEmpty() == false) {
|
|
|
- deprecationLogger.warn(DeprecationCategory.SETTINGS, "transient_settings", TRANSIENT_SETTINGS_DEPRECATION_MESSAGE);
|
|
|
- }
|
|
|
- clusterUpdateSettingsRequest.transientSettings(transientSettings);
|
|
|
+ clusterUpdateSettingsRequest.transientSettings((Map<String, ?>) source.get(TRANSIENT));
|
|
|
}
|
|
|
if (source.containsKey(PERSISTENT)) {
|
|
|
clusterUpdateSettingsRequest.persistentSettings((Map<String, ?>) source.get(PERSISTENT));
|