fixes

Signed-off-by: Kai Huang <ahkcs@amazon.com>

Author: ahkcs

core/src/main/java/org/opensearch/sql/expression/function/udf/binning/MinspanBucketFunction.java

@@ -38,7 +38,7 @@
 public class MinspanBucketFunction extends ImplementorUDF {
 
   public MinspanBucketFunction() {
-    super(new MinspanBucketImplementor(), NullPolicy.ANY);
+    super(new MinspanBucketImplementor(), NullPolicy.NONE);
   }
 
   @Override

core/src/main/java/org/opensearch/sql/expression/function/udf/binning/RangeBucketFunction.java

@@ -42,7 +42,7 @@
 public class RangeBucketFunction extends ImplementorUDF {
 
   public RangeBucketFunction() {
-    super(new RangeBucketImplementor(), NullPolicy.ANY);
+    super(new RangeBucketImplementor(), NullPolicy.NONE);
   }
 
   @Override

core/src/main/java/org/opensearch/sql/expression/function/udf/binning/SpanBucketFunction.java

@@ -36,7 +36,7 @@
 public class SpanBucketFunction extends ImplementorUDF {
 
   public SpanBucketFunction() {
-    super(new SpanBucketImplementor(), NullPolicy.ANY);
+    super(new SpanBucketImplementor(), NullPolicy.NONE);
   }
 
   @Override

core/src/main/java/org/opensearch/sql/expression/function/udf/binning/WidthBucketFunction.java

@@ -43,7 +43,7 @@
 public class WidthBucketFunction extends ImplementorUDF {
 
   public WidthBucketFunction() {
-    super(new WidthBucketImplementor(), NullPolicy.ANY);
+    super(new WidthBucketImplementor(), NullPolicy.NONE);
   }
 
   @Override

integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalciteBinCommandIT.java

@@ -1076,13 +1076,13 @@ public void testBinOnNonNumericStringField() {
         assertThrows(
             ResponseException.class,
             () -> {
-              executeQuery(
-                  String.format("source=%s | bin firstname bins=3 | head 1", TEST_INDEX_ACCOUNT));
+              executeQuery(String.format("source=%s | bin firstname bins=3", TEST_INDEX_ACCOUNT));
             });
 
+    // Verify the error message contains information about non-numeric string values
     String errorMessage = exception.getMessage();
     assertTrue(
-        "Error should indicate non-numeric string values",
+        "Error message should indicate non-numeric string values: " + errorMessage,
         errorMessage.contains("non-numeric string values"));
   }
 }