bx123 created FLINK-24994:
-----------------------------
Summary: WindowedStream#reduce(ReduceFunction<T> function) gives
useless suggestion when reducefunction is richfunction.
Key: FLINK-24994
URL: https://issues.apache.org/jira/browse/FLINK-24994
Project: Flink
Issue Type: Bug
Components: API / DataStream
Reporter: bx123
1. when reducefunction is really a richfunction, the exception suggests to use
reduce(ReduceFunction, WindowFunction) instead. While this is useless, we can
tests this by just call(richreducefunction, new PassThroughWindowFunction<>())
ourself.
this wrong suggestion appeares in AllWindowedStream too.
2.AggerateFunction should not be richfunction not just when used in
WindowedStream/AllWindowedStream#aggerate(). this should be checked when it is
used in a StateDescriptor.
3. Typically, when reducefunction/aggeratefunction is used in a StateDescriptor
and it is a richfunction. The lifecycle method open/close has no chance to be
called and the operation in open/close will not be processed. and the
runtimecontext will always be null as we cannot set it.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
