jeff-zou

``` public class TestAggregateFunction extends AggregateFunction { public void accumulate(TestAggregateAcc acc, String param1, String param2, String param3) { acc.test = param1 + param2 + param3; } @Override public String getValue(TestAggregateAcc...

multi-tier udf eg: `round( COUNT(*) / COUNT( DISTINCT col1) , 2 )` 

 ``` public class TestAggregateFunction extends AggregateFunction { public void accumulate(TestAggregateAcc acc, String param1, String param2, String param3) { acc.test = param1 + param2 + param3; } @Override public String...

[FLINK-37585] [cdc-connector][mysql] Fixed the data of the newly added table cannot be read

2

Fixed the data of the newly added table cannot be read