Hi,

sorry I forgot to further investigate this issue. It seems the last refactoring of the code base caused this documented feature to break. I opened an issue for it:

https://issues.apache.org/jira/browse/FLINK-21225

For now, I would suggest to use SQL for the same behavior. I hope someone can fix the translation layer for Table API soon.

Regards,
Timo


On 30.01.21 05:10, Appleyuchi wrote:

I posted this question here.
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Unknown-call-expression-avg-amount-when-use-distinct-in-Flink-Thanks-td40905.html <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Unknown-call-expression-avg-amount-when-use-distinct-in-Flink-Thanks-td40905.html>
but my later replies to it is NOT delivered,it's strange.

Flink1.12
scala2.12

Could anyone help me?

Thanks~!






Reply via email to