fix: add NP checks in parse()

emptyOVO · Dec 30, 2024 · e7271f2 · e7271f2
1 parent 3cff53e
commit e7271f2
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/...n/java/org/apache/inlong/sdk/transform/process/function/arithmetic/FibonacciFunction.java b/...n/java/org/apache/inlong/sdk/transform/process/function/arithmetic/FibonacciFunction.java
@@ -57,9 +57,15 @@ public FibonacciFunction(Function expr) {
 
     @Override
     public Object parse(SourceData sourceData, int rowIndex, Context context) {
-        Object numberObj = numberParser.parse(sourceData, rowIndex, context);
-        BigDecimal numberValue = OperatorTools.parseBigDecimal(numberObj);
-        return fibonacci(numberValue.intValue());
+        if (numberParser != null) {
+            Object valueObj = numberParser.parse(sourceData, rowIndex, context);
+            if (valueObj == null) {
+                return null;
+            }
+            BigDecimal numberValue = OperatorTools.parseBigDecimal(valueObj);
+            return fibonacci(numberValue.intValue());
+        }
+        return null;
     }
 
     private long fibonacci(int n) {