Bug Fix

Signed-off-by: Varun Jain <[email protected]>
opensearch-project · Dec 26, 2023 · e400e06 · e400e06
1 parent eccaf2a
commit e400e06
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 9 deletions.
diff --git a/qa/rolling-upgrade/src/test/java/org/opensearch/neuralsearch/bwc/SemanticSearch.java b/qa/rolling-upgrade/src/test/java/org/opensearch/neuralsearch/bwc/SemanticSearch.java
@@ -9,13 +9,11 @@
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.util.Map;
-import lombok.extern.log4j.Log4j2;
 import org.opensearch.neuralsearch.TestUtils;
 import static org.opensearch.neuralsearch.TestUtils.NODES_BWC_CLUSTER;
 import static org.opensearch.neuralsearch.TestUtils.TEXT_EMBEDDING_PROCESSOR;
 import org.opensearch.neuralsearch.query.NeuralQueryBuilder;
 
-@Log4j2
 public class SemanticSearch extends AbstractRollingUpgradeTestCase{
     private static final String PIPELINE_NAME = "nlp-pipeline";
     private static final String TEST_FIELD = "test-field";
@@ -25,7 +23,7 @@ public class SemanticSearch extends AbstractRollingUpgradeTestCase{
     private static final int NUM_DOCS = 1;
 
     public void testSemanticSearch() throws Exception{
-        log.info("Get Cluster Type=========================="+getClusterType());
+        logger.info("Get Cluster Type=========================="+getClusterType());
         getIndices();
         getShards();
         waitForClusterHealthGreen(NODES_BWC_CLUSTER);

diff --git a/src/testFixtures/java/org/opensearch/neuralsearch/BaseNeuralSearchIT.java b/src/testFixtures/java/org/opensearch/neuralsearch/BaseNeuralSearchIT.java
@@ -54,10 +54,8 @@
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.SneakyThrows;
-import lombok.extern.log4j.Log4j2;
 
 @ThreadLeakScope(ThreadLeakScope.Scope.NONE)
-@Log4j2
 public abstract class BaseNeuralSearchIT extends OpenSearchSecureRestTestCase {
 
     protected static final Locale LOCALE = Locale.ROOT;
@@ -860,17 +858,17 @@ protected void getIndices() {
         Request request = new Request("GET", "/_cat/indices");
         Response response = client().performRequest(request);
         String responseBody = EntityUtils.toString(response.getEntity());
-        log.info("Indices are ============================");
-        log.info(responseBody);
+        logger.info("Indices are ============================");
+        logger.info(responseBody);
     }
 
     @SneakyThrows
     protected void getShards() {
         Request request = new Request("GET", "/_cat/shards");
         Response response = client().performRequest(request);
         String responseBody = EntityUtils.toString(response.getEntity());
-        log.info("Shards are ============================");
-        log.info(responseBody);
+        logger.info("Shards are ============================");
+        logger.info(responseBody);
     }
 
     /**