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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Appleyuchi

I posted this question here.
but my replies to it is now delivered,it's strange.

Flink1.12
scala2.12

Could anyone help me?

Thanks~!