Added validation for nested fields in field_map

Signed-off-by: Sanjana679 <[email protected]>
opensearch-project · Nov 13, 2023 · 0e38fea · 0e38fea
1 parent a5b1c4a
commit 0e38fea
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/org/opensearch/neuralsearch/processor/InferenceProcessor.java b/src/main/java/org/opensearch/neuralsearch/processor/InferenceProcessor.java
@@ -6,6 +6,7 @@
 package org.opensearch.neuralsearch.processor;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
@@ -82,7 +83,9 @@ private void validateEmbeddingConfiguration(Map<String, Object> fieldMap) {
                 || fieldMap.entrySet()
                         .stream()
                         .anyMatch(
-                                x -> StringUtils.isBlank(x.getKey()) || Objects.isNull(x.getValue())
+                                x -> StringUtils.startsWith(x.getKey(), ".") || StringUtils.endsWith(x.getKey(), ".")
+                                        || Arrays.stream(x.getKey().split("\\.")).anyMatch(y -> StringUtils.isBlank(y))
+                                        || Objects.isNull(x.getValue())
                                         || StringUtils.isBlank(x.getValue().toString()))) {
             throw new IllegalArgumentException("Unable to create the processor as field_map has invalid key or value");
         }