This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a commit to branch 2.1.4-prepare
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/2.1.4-prepare by this push:
new e35e026ea [Hotfix][Connector-V1][Flink] Transfrom-flink-udf function
properties get error (#3422)
e35e026ea is described below
commit e35e026ea7fb2443d6bca982855b2ccd8d3a9685
Author: Kirs <[email protected]>
AuthorDate: Mon Nov 14 13:59:42 2022 +0800
[Hotfix][Connector-V1][Flink] Transfrom-flink-udf function properties get
error (#3422)
Co-authored-by: lucifer1024 <[email protected]>
---
.../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 7c5d7f2e3..298b0bad1 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
@@ -99,7 +99,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));
});
}