Hi Arujit,
Thanks for reporting this. Are you using this UDF in window aggregation in
old planner ?
AFAIK, open() method of UDAF is only not called in window aggregation in
old planner,
because old planner uses DataStream WindowOperator which will not call
open() on AggregateFunction [1].
I also
At least I hope it has been fixed. Which version and planner are you using?
On 11.12.19 11:47, Arujit Pradhan wrote:
Hi Timo,
Thanks for the bug reference.
You mentioned that this bug has been fixed. Is the fix available for
flink 1.9+ and default query planner.
Thanks and regards,
/Arujit
I remember that we fixed some bug around this topic recently. The legacy
planner should not be affected.
There is another user reporting this:
https://issues.apache.org/jira/browse/FLINK-15040
Regards,
Timo
On 11.12.19 10:34, Dawid Wysakowicz wrote:
Hi Arujit,
Could you also share the query
Hi Arujit,
Could you also share the query where you use this UDF? It would also
help if you said which version of Flink you are using and which planner.
Best,
Dawid
On 11/12/2019 10:21, Arujit Pradhan wrote:
> Hi all,
>
> So we are creating some User Defined Functions of type
> AggregateFunctio
Hi all,
So we are creating some User Defined Functions of type AggregateFunction.
And we want to send some static metrics from the *open()* method of the
UDFs as we can get *MetricGroup *by *FunctionContext *which is only exposed
in the open method. Our code looks something like this(Which is an
i
