seatunnel
seatunnel copied to clipboard
[Bug] [seatunel-transform-flink-udf] udf prepare method properties analysis error
Search before asking
- [X] I had searched in the issues and found no similar issues.
What happened
` public void prepare(FlinkEnvironment prepareEnv) {
final Properties properties = new Properties();
PropertiesUtil.setProperties(config, properties, UDF_CONFIG_PREFIX, false);
classNames = new ArrayList<>(properties.size());
functionNames = new ArrayList<>(properties.size());
properties.forEach((k, v) -> {
classNames.add(String.valueOf(k));
functionNames.add(String.valueOf(k));
});
}
`
udf { function.test_1 = "com.example.udf.flink.TestUDF" function.test_2 = "com.example.udf.flink.TestUDTF" }
classNames.add(String.valueOf(k))
error, is not k ,
it should be v , classNames.add(String.valueOf(v))
SeaTunnel Version
dev
SeaTunnel Config
empty
Running Command
empty
Error Exception
empty
Flink or Spark Version
empty
Java or Scala Version
No response
Screenshots
No response
Are you willing to submit PR?
- [X] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct
This is an obvious mistake. Looking forward your PR!
What‘s happend ? If this is a bug, I will reopen it.
If you don't have enough time to fix it, maybe others can help to do it.
Hi, assign me please.
If you don't have enough time to fix it, maybe others can help to do it.
What‘s happend ? If this is a bug, I will reopen it.
Sorry , I thought it was fixed in #3171
I to fix it