Hi Yuxin,
Thanks for the reply.
> For idempotence annotation, what's the specific behavior?
StreamTask will reduce the frequency of output record, which will
have a default value and can also be set through configuration options.
The specific rules will be described in detail in the subsequent FL
911432 created FLINK-35775:
--
Summary: README.md changes
Key: FLINK-35775
URL: https://issues.apache.org/jira/browse/FLINK-35775
Project: Flink
Issue Type: Improvement
Affects Versions: 1.20.0
Hi Jeyhun,
Thanks for working on this FLIP.
In general, I think it's a good idea to generalize the concept of Watermark
to not only representing the advancing of event time, but general
indicators / events / signals that need to be passed along the data
streams. So +1 for working towards this dir
+1 (non-binding)
Best,
Yubin
On Fri, Jul 5, 2024 at 4:09 AM Ferenc Csaky wrote:
>
> +1 (non-binding)
>
> Best,
> Ferenc
>
>
>
>
> On Thursday, 4 July 2024 at 16:20, Feng Jin wrote:
>
> >
> >
> > +1 (non-binding)
> >
> > Best,
> > Feng Jin
> >
> > On Thu, Jul 4, 2024 at 6:02 PM Martijn Visser ma
Gyula Fora created FLINK-35776:
--
Summary: Simplify job observe logic
Key: FLINK-35776
URL: https://issues.apache.org/jira/browse/FLINK-35776
Project: Flink
Issue Type: Improvement
Comp
