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

kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 13baee276 [BUG][transform] transfrom-flink-udf function properties get 
error (#3310)
13baee276 is described below

commit 13baee2765aee5b6f13071fbb7af4f3f34374d4e
Author: lucifer1024 <[email protected]>
AuthorDate: Wed Nov 9 13:25:24 2022 +0800

    [BUG][transform] transfrom-flink-udf function properties get error (#3310)
---
 .../src/main/java/org/apache/seatunnel/flink/transform/UDF.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/java/org/apache/seatunnel/flink/transform/UDF.java
 
b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/java/org/apache/seatunnel/flink/transform/UDF.java
index c55f9b8da..aaaca0d9a 100644
--- 
a/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/java/org/apache/seatunnel/flink/transform/UDF.java
+++ 
b/seatunnel-transforms/seatunnel-transforms-flink/seatunnel-transform-flink-udf/src/main/java/org/apache/seatunnel/flink/transform/UDF.java
@@ -98,7 +98,7 @@ public class UDF implements FlinkStreamTransform, 
FlinkBatchTransform {
         functionNames = new ArrayList<>(properties.size());
 
         properties.forEach((k, v) -> {
-            classNames.add(String.valueOf(k));
+            classNames.add(String.valueOf(v));
             functionNames.add(String.valueOf(k));
         });
     }

Reply via email to