From 11d5eea32961d674f7b4d40ce505c7429d8a15f0 Mon Sep 17 00:00:00 2001 From: zane-neo Date: Wed, 6 Dec 2023 09:50:40 +0800 Subject: [PATCH] Fix IT failure and format code Signed-off-by: zane-neo --- .../sql/plugin/rest/RestPPLQueryAction.java | 2 -- .../plugin/transport/TransportPPLQueryAction.java | 14 ++++++++------ 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestPPLQueryAction.java b/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestPPLQueryAction.java index 3358137fb3..d35962be91 100644 --- a/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestPPLQueryAction.java +++ b/plugin/src/main/java/org/opensearch/sql/plugin/rest/RestPPLQueryAction.java @@ -15,7 +15,6 @@ import java.util.HashSet; import java.util.List; import java.util.Set; -import java.util.function.Supplier; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.opensearch.OpenSearchSecurityException; @@ -28,7 +27,6 @@ import org.opensearch.rest.RestChannel; import org.opensearch.rest.RestRequest; import org.opensearch.sql.common.antlr.SyntaxCheckException; -import org.opensearch.sql.common.setting.Settings; import org.opensearch.sql.datasources.exceptions.DataSourceClientException; import org.opensearch.sql.exception.ExpressionEvaluationException; import org.opensearch.sql.exception.QueryEngineException; diff --git a/plugin/src/main/java/org/opensearch/sql/plugin/transport/TransportPPLQueryAction.java b/plugin/src/main/java/org/opensearch/sql/plugin/transport/TransportPPLQueryAction.java index 047a556561..76283ac63a 100644 --- a/plugin/src/main/java/org/opensearch/sql/plugin/transport/TransportPPLQueryAction.java +++ b/plugin/src/main/java/org/opensearch/sql/plugin/transport/TransportPPLQueryAction.java @@ -11,7 +11,6 @@ import java.util.Locale; import java.util.Optional; import java.util.function.Supplier; - import org.opensearch.action.ActionRequest; import org.opensearch.action.support.ActionFilters; import org.opensearch.action.support.HandledTransportAction; @@ -61,7 +60,6 @@ public TransportPPLQueryAction( NodeClient client, ClusterService clusterService, DataSourceServiceImpl dataSourceService, - Settings pluginSettings, org.opensearch.common.settings.Settings clusterSettings) { super(PPLQueryAction.NAME, transportService, actionFilters, TransportPPLQueryRequest::new); @@ -78,7 +76,10 @@ public TransportPPLQueryAction( this.pplEnabled = () -> MULTI_ALLOW_EXPLICIT_INDEX.get(clusterSettings) - && (Boolean) pluginSettings.getSettingValue(Settings.Key.PPL_ENABLED); + && (Boolean) + injector + .getInstance(org.opensearch.sql.common.setting.Settings.class) + .getSettingValue(Settings.Key.PPL_ENABLED); } /** @@ -89,9 +90,10 @@ public TransportPPLQueryAction( protected void doExecute( Task task, ActionRequest request, ActionListener listener) { if (!pplEnabled.get()) { - listener.onFailure(new IllegalAccessException( - "Either plugins.ppl.enabled or rest.action.multi.allow_explicit_index setting is" - + " false")); + listener.onFailure( + new IllegalAccessException( + "Either plugins.ppl.enabled or rest.action.multi.allow_explicit_index setting is" + + " false")); return; } Metrics.getInstance().getNumericalMetric(MetricName.PPL_REQ_TOTAL).increment();