SubType in Map data types?
zhouhaifengmath
I try to use the same SQL(Flink: 1.14) as streaming in batch to calculate every minute distinct user count, in order to repair the wrong result in streaming, but it give errors: `DISTINCT aggregates are currently not supported.`I wonder why DISTINCT aggregates is not supported? A
Hi,
I am trying to test a flink sql udf which has open method to get some parameters with Flink1.14, but i can't find an example to set those parameters in a test. Can someone give me a example on this question? Thanks for your help~Thanks && Regards
s, or some other parameters?
Best,
Zhanghao Chen
From: zhouhaifengmath
Sent: Thursday, May 12, 2022 14:33
To: user@flink.apache.org
Subject: How to test Flink SQL UDF with open method?
Hi,
I am trying to test a flink sql udf which has open method to get some parameters