Hi,
IIUC, Conditions to reproduce it are:
1. Using RocksDBStateBackend with incremental strategy
2. Using ListState in the stateful operator
3. enabling TTL with cleanupInRocksdbCompactFilter
4. adding a field to make the job trigger schema evolution
Then the exception will be thrown, right?
As fo
Hi, what you want is UDAF? Please check whether this[1] is meet your
requirement.
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/udfs/#aggregate-functions
在 2022-08-07 22:06:29，"wang" <24248...@163.com> 写道：
Hi dear engineers,
One small question: does fli
Hi David,
Thanks for confirming my research. Adding some more up to date
documentation to that function seems like an easy first contribution.
Best,
Ben
The configuration parameter passed to the open method is a legacy holdover
that has been retained to avoid breaking a public API, but is no longer
used.
Your options are to either get the global job parameters from the execution
context as described in [1], or to pass the configuration to a constr
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!
Rega
