Flink SQL: HOW to define `ANY` subtype in constructured Constructured Data Types(MAP, ARRAY...)

SubType in Map data types? zhouhaifengmath

[Flink Batch SQL] Why DISTINCT aggregates not support =?utf-8?Q?in_Group_Window_Aggregation??=

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

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

Re: How to test Flink SQL UDF with open method?

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