Hi dear engineers,

I have one question:  does flink streaming support getting the state.I override 
the open method in the map processor,initializing
Hi dear engineers,


One small question:  does flink sql support UDTAGG? (user-defined table 
aggregate function), seems only supported in flink table api? If not supported 
in flink sql, how can I define an aggregated udf which could output multiple 
rows to kafka.


Thanks for your help!
Thanks for your help!

回复