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

2021-02-01 Thread Timo Walther
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 <h

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

2021-01-29 Thread 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~!

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

2021-01-29 Thread 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 replies to it is now delivered,it's strange. Flink1.12 scala2.12 Could anyone help me? Thanks~!

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

2021-01-22 Thread Timo Walther
Hi, I'm assuming you are using Flink 1.12? The exception indicates that something is definitely going wrong with the translation from Table API to optimizer nodes. We refactored a lot of this code in this region. I investogate the issue and come back to you once I opended a ticket. Thanks f

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

2021-01-22 Thread Appleyuchi
I'm testing https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.html the part "Distinct aggregation on over window"(Ctrl+f and search the whole above string in above link please) test code distinctaggregation3.java https://paste.ubuntu.com/p/7HJ9W3hVVN/ POJO needed