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;
}
}