Consolidate vector embedding tests into SearchIndexAppTest

Merge 3 separate full-app vector embedding test classes
(SearchIndexVectorEmbeddingTest, VectorEmbeddingReindexAppTest,
VectorEmbeddingReembedOperationsTest) into SearchIndexAppTest to avoid
starting infrastructure 3 times. Keep VectorEmbeddingIntegrationIT in
openmetadata-integration-tests since it's self-contained with its own
testcontainers.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: pmbrull

…ctor/VectorEmbeddingIntegrationTest.java …/tests/VectorEmbeddingIntegrationIT.javaopenmetadata-service/src/test/java/org/openmetadata/service/search/vector/VectorEmbeddingIntegrationTest.java renamed to openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/VectorEmbeddingIntegrationIT.java openmetadata-service/src/test/java/org/openmetadata/service/search/vector/VectorEmbeddingIntegrationTest.java renamed to openmetadata-integration-tests/src/test/java/org/openmetadata/it/tests/VectorEmbeddingIntegrationIT.java

@@ -1,4 +1,4 @@
-package org.openmetadata.service.search.vector;
+package org.openmetadata.it.tests;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
@@ -24,6 +24,8 @@
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
 import org.openmetadata.schema.entity.data.Table;
+import org.openmetadata.service.search.vector.OpenSearchVectorService;
+import org.openmetadata.service.search.vector.VectorDocBuilder;
 import org.openmetadata.service.search.vector.client.DjlEmbeddingClient;
 import org.openmetadata.service.search.vector.client.DjlEmbeddingClient.EmbeddingInitializationException;
 import org.opensearch.testcontainers.OpensearchContainer;
@@ -37,7 +39,7 @@
 
 @Testcontainers
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
-class VectorEmbeddingIntegrationTest {
+class VectorEmbeddingIntegrationIT {
 
   @Container
   static OpensearchContainer<?> opensearch =

openmetadata-service/src/main/java/org/openmetadata/service/search/vector/VectorSearchQueryBuilder.java

@@ -6,9 +6,12 @@
 import java.util.List;
 import java.util.Map;
 import lombok.experimental.UtilityClass;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 @UtilityClass
 public class VectorSearchQueryBuilder {
+  private static final Logger LOG = LoggerFactory.getLogger(VectorSearchQueryBuilder.class);
   private static final String ANY = "__ANY__";
   private static final String NONE = "__NONE__";
 
@@ -37,23 +40,41 @@ public static String build(float[] vector, int size, int k, Map<String, List<Str
       List<String> values = e.getValue();
       if (values == null || values.isEmpty()) continue;
 
-      sb.append(','); // Add comma before each filter
-
       // Handle custom properties that will come with "customProperties.<name>"
       if (field.startsWith("customProperties.")) {
+        sb.append(',');
         appendCustomPropertiesFilter(sb, field, values);
       } else {
-
         switch (field) {
-          case "owners" -> appendOwnersFilter(sb, values);
-          case "tags" -> appendNested(sb, "tags", "tags.tagFQN", values);
-          case "domains" -> appendFlat(sb, "domains.name", values);
-          case "tier" -> appendFlat(sb, "tier.tagFQN", values);
-          case "certification" -> appendFlat(sb, "certification.tagFQN", values);
-          case "entityType" -> appendFlat(sb, "entityType", values);
-          case "serviceType" -> appendFlat(sb, "serviceType", values);
-
-          default -> {}
+          case "owners" -> {
+            sb.append(',');
+            appendOwnersFilter(sb, values);
+          }
+          case "tags" -> {
+            sb.append(',');
+            appendNested(sb, "tags", "tags.tagFQN", values);
+          }
+          case "domains" -> {
+            sb.append(',');
+            appendFlat(sb, "domains.name", values);
+          }
+          case "tier" -> {
+            sb.append(',');
+            appendFlat(sb, "tier.tagFQN", values);
+          }
+          case "certification" -> {
+            sb.append(',');
+            appendFlat(sb, "certification.tagFQN", values);
+          }
+          case "entityType" -> {
+            sb.append(',');
+            appendFlat(sb, "entityType", values);
+          }
+          case "serviceType" -> {
+            sb.append(',');
+            appendFlat(sb, "serviceType", values);
+          }
+          default -> LOG.debug("Ignoring unrecognized filter key: {}", field);
         }
       }
     }