This is an automated email from the ASF dual-hosted git repository.

healchow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 873bfdd7e [INLONG-3816][Sort] Fix NPE in RegexpReplaceFirstFunction 
(#4057)
873bfdd7e is described below

commit 873bfdd7e7aa06489f8961dc4ae9b70b6cbad5d3
Author: yunqingmoswu <[email protected]>
AuthorDate: Sun May 1 17:18:41 2022 +0800

    [INLONG-3816][Sort] Fix NPE in RegexpReplaceFirstFunction (#4057)
---
 .../sort/singletenant/flink/function/RegexpReplaceFirstFunction.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/function/RegexpReplaceFirstFunction.java
 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/function/RegexpReplaceFirstFunction.java
index 4a0146e7a..93d320f9a 100644
--- 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/function/RegexpReplaceFirstFunction.java
+++ 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/function/RegexpReplaceFirstFunction.java
@@ -35,7 +35,10 @@ public class RegexpReplaceFirstFunction extends 
ScalarFunction {
      * @return replaced value
      */
     public String eval(String field, String regex, String replacement) {
-        return field.replaceFirst(regex, replacement);
+        if (field != null) {
+            return field.replaceFirst(regex, replacement);
+        }
+        return field;
     }
 
 }

Reply via email to