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