Unknown call expression: avg(amount) when use distinct() in Flink Thanks~!

[Appleyuchi]

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

but my later replies to it is NOT delivered,it's strange.

Flink1.12

scala2.12

Could anyone help me?

Thanks~!

 

 

[Timo Walther]

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