seatunnel icon indicating copy to clipboard operation
seatunnel copied to clipboard

[Bug] [seatunel-transform-flink-udf] udf prepare method properties analysis error

Open lucifer1024 opened this issue 2 years ago • 1 comments

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

lucifer1024 avatar Nov 01 '22 07:11 lucifer1024

This is an obvious mistake. Looking forward your PR!

Hisoka-X avatar Nov 02 '22 03:11 Hisoka-X

What‘s happend ? If this is a bug, I will reopen it.

Hisoka-X avatar Nov 04 '22 10:11 Hisoka-X

If you don't have enough time to fix it, maybe others can help to do it.

Hisoka-X avatar Nov 04 '22 10:11 Hisoka-X

Hi, assign me please.

If you don't have enough time to fix it, maybe others can help to do it.

shengdoupi avatar Nov 04 '22 14:11 shengdoupi

What‘s happend ? If this is a bug, I will reopen it.

Sorry , I thought it was fixed in #3171

lucifer1024 avatar Nov 05 '22 07:11 lucifer1024

I to fix it

lucifer1024 avatar Nov 05 '22 07:11 lucifer1024