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