[incubator-inlong] branch master updated: [INLONG-3823][Sort] Fix error caused by unregistered custom function (#4053)

[healchow]

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 1586be0f2 [INLONG-3823][Sort] Fix error caused by unregistered custom 
function (#4053)
1586be0f2 is described below

commit 1586be0f2172d08877bab71ac86e672199fbe004
Author: yunqingmoswu <44659300+yunqingmo...@users.noreply.github.com>
AuthorDate: Sun May 1 17:13:09 2022 +0800

    [INLONG-3823][Sort] Fix error caused by unregistered custom function (#4053)
---
 .../sort/singletenant/flink/parser/impl/FlinkSqlParser.java      | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/parser/impl/FlinkSqlParser.java
 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/parser/impl/FlinkSqlParser.java
index e481b09ff..f900b2305 100644
--- 
a/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/parser/impl/FlinkSqlParser.java
+++ 
b/inlong-sort/sort-single-tenant/src/main/java/org/apache/inlong/sort/singletenant/flink/parser/impl/FlinkSqlParser.java
@@ -41,6 +41,7 @@ import 
org.apache.inlong.sort.protocol.transformation.FunctionParam;
 import 
org.apache.inlong.sort.protocol.transformation.relation.JoinRelationShip;
 import 
org.apache.inlong.sort.protocol.transformation.relation.NodeRelationShip;
 import 
org.apache.inlong.sort.protocol.transformation.relation.UnionNodeRelationShip;
+import 
org.apache.inlong.sort.singletenant.flink.function.RegexpReplaceFirstFunction;
 import org.apache.inlong.sort.singletenant.flink.parser.Parser;
 import 
org.apache.inlong.sort.singletenant.flink.parser.result.FlinkSqlParseResult;
 import org.slf4j.Logger;
@@ -80,6 +81,7 @@ public class FlinkSqlParser implements Parser {
     public FlinkSqlParser(TableEnvironment tableEnv, GroupInfo groupInfo) {
         this.tableEnv = tableEnv;
         this.groupInfo = groupInfo;
+        registerUDF();
     }
 
     /**
@@ -93,6 +95,13 @@ public class FlinkSqlParser implements Parser {
         return new FlinkSqlParser(tableEnv, groupInfo);
     }
 
+    /**
+     * Register udf
+     */
+    private void registerUDF() {
+        tableEnv.createTemporarySystemFunction("REGEXP_REPLACE_FIRST", 
RegexpReplaceFirstFunction.class);
+    }
+
     /**
      * Sql parse entrance
      *