fix: add NP check

emptyOVO · Sep 7, 2024 · 60a7db1 · 60a7db1
1 parent c249ab9
commit 60a7db1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...rm-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RepeatFunction.java b/...rm-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RepeatFunction.java
@@ -48,6 +48,9 @@ public RepeatFunction(Function expr) {
     public Object parse(SourceData sourceData, int rowIndex, Context context) {
         Object stringObj = stringParser.parse(sourceData, rowIndex, context);
         Object countObj = countParser.parse(sourceData, rowIndex, context);
+        if (stringObj == null || countObj == null) {
+            return null;
+        }
         if (stringObj.equals("") || countObj.equals("")) {
             return "";
         }