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~!