[VOTE] Watermark propagation with Sink API

2021-06-01 Thread Eron Wright
After some good discussion about how to enhance the Sink API to process
watermarks, I believe we're ready to proceed with a vote.  Voting will be
open until at least Friday, June 4th, 2021.

Reference:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-167%3A+Watermarks+for+Sink+API

Discussion thread:
https://lists.apache.org/thread.html/r5194e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e%40%3Cdev.flink.apache.org%3E

Implementation Issue:
https://issues.apache.org/jira/browse/FLINK-22700

Thanks,
Eron Wright
StreamNative


Re: [VOTE] Watermark propagation with Sink API

2021-06-02 Thread Arvid Heise
+1 (binding)

Thanks Eron for driving this effort; it will open up new exciting use cases.

On Tue, Jun 1, 2021 at 7:17 PM Eron Wright 
wrote:

> After some good discussion about how to enhance the Sink API to process
> watermarks, I believe we're ready to proceed with a vote.  Voting will be
> open until at least Friday, June 4th, 2021.
>
> Reference:
>
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-167%3A+Watermarks+for+Sink+API
>
> Discussion thread:
>
> https://lists.apache.org/thread.html/r5194e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e%40%3Cdev.flink.apache.org%3E
>
> Implementation Issue:
> https://issues.apache.org/jira/browse/FLINK-22700
>
> Thanks,
> Eron Wright
> StreamNative
>


RE: [VOTE] Watermark propagation with Sink API

2021-06-02 Thread Zhou, Brian
+1 (non-binding)

Thanks Eron, looking forward to seeing this feature soon.

Thanks,
Brian

-Original Message-
From: Arvid Heise  
Sent: Wednesday, June 2, 2021 15:44
To: dev
Subject: Re: [VOTE] Watermark propagation with Sink API


[EXTERNAL EMAIL] 

+1 (binding)

Thanks Eron for driving this effort; it will open up new exciting use cases.

On Tue, Jun 1, 2021 at 7:17 PM Eron Wright 
wrote:

> After some good discussion about how to enhance the Sink API to 
> process watermarks, I believe we're ready to proceed with a vote.  
> Voting will be open until at least Friday, June 4th, 2021.
>
> Reference:
>
> https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$ 
> [cwiki[.]apache[.]org]
>
> Discussion thread:
>
> https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> ache.org*3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
>
> Implementation Issue:
> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> N6AJm4h$ [issues[.]apache[.]org]
>
> Thanks,
> Eron Wright
> StreamNative
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-03 Thread Dawid Wysakowicz
+1 (binding)

Best,

Dawid

On 03/06/2021 03:50, Zhou, Brian wrote:
> +1 (non-binding)
>
> Thanks Eron, looking forward to seeing this feature soon.
>
> Thanks,
> Brian
>
> -Original Message-
> From: Arvid Heise  
> Sent: Wednesday, June 2, 2021 15:44
> To: dev
> Subject: Re: [VOTE] Watermark propagation with Sink API
>
>
> [EXTERNAL EMAIL] 
>
> +1 (binding)
>
> Thanks Eron for driving this effort; it will open up new exciting use cases.
>
> On Tue, Jun 1, 2021 at 7:17 PM Eron Wright 
> wrote:
>
>> After some good discussion about how to enhance the Sink API to 
>> process watermarks, I believe we're ready to proceed with a vote.  
>> Voting will be open until at least Friday, June 4th, 2021.
>>
>> Reference:
>>
>> https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
>> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
>> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$ 
>> [cwiki[.]apache[.]org]
>>
>> Discussion thread:
>>
>> https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
>> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
>> ache.org*3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
>> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
>>
>> Implementation Issue:
>> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
>> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
>> N6AJm4h$ [issues[.]apache[.]org]
>>
>> Thanks,
>> Eron Wright
>> StreamNative
>>



OpenPGP_signature
Description: OpenPGP digital signature


Re: [VOTE] Watermark propagation with Sink API

2021-06-03 Thread Jark Wu
+1 (binding)

Best,
Jark

On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz 
wrote:

> +1 (binding)
>
> Best,
>
> Dawid
>
> On 03/06/2021 03:50, Zhou, Brian wrote:
> > +1 (non-binding)
> >
> > Thanks Eron, looking forward to seeing this feature soon.
> >
> > Thanks,
> > Brian
> >
> > -Original Message-
> > From: Arvid Heise 
> > Sent: Wednesday, June 2, 2021 15:44
> > To: dev
> > Subject: Re: [VOTE] Watermark propagation with Sink API
> >
> >
> > [EXTERNAL EMAIL]
> >
> > +1 (binding)
> >
> > Thanks Eron for driving this effort; it will open up new exciting use
> cases.
> >
> > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright  .invalid>
> > wrote:
> >
> >> After some good discussion about how to enhance the Sink API to
> >> process watermarks, I believe we're ready to proceed with a vote.
> >> Voting will be open until at least Friday, June 4th, 2021.
> >>
> >> Reference:
> >>
> >> https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> >> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> >> [cwiki[.]apache[.]org]
> >>
> >> Discussion thread:
> >>
> >> https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> >> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> >> ache.org*3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> >>
> >> Implementation Issue:
> >> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> >> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> >> N6AJm4h$ [issues[.]apache[.]org]
> >>
> >> Thanks,
> >> Eron Wright
> >> StreamNative
> >>
>
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-03 Thread Piotr Nowojski
I would like to ask you to hold on with counting the votes until I get an
answer for my one question in the dev mailing list thread (sorry if it was
already covered somewhere).

Best, Piotrek

czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):

> +1 (binding)
>
> Best,
> Jark
>
> On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz 
> wrote:
>
> > +1 (binding)
> >
> > Best,
> >
> > Dawid
> >
> > On 03/06/2021 03:50, Zhou, Brian wrote:
> > > +1 (non-binding)
> > >
> > > Thanks Eron, looking forward to seeing this feature soon.
> > >
> > > Thanks,
> > > Brian
> > >
> > > -Original Message-----
> > > From: Arvid Heise 
> > > Sent: Wednesday, June 2, 2021 15:44
> > > To: dev
> > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > >
> > >
> > > [EXTERNAL EMAIL]
> > >
> > > +1 (binding)
> > >
> > > Thanks Eron for driving this effort; it will open up new exciting use
> > cases.
> > >
> > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright  > .invalid>
> > > wrote:
> > >
> > >> After some good discussion about how to enhance the Sink API to
> > >> process watermarks, I believe we're ready to proceed with a vote.
> > >> Voting will be open until at least Friday, June 4th, 2021.
> > >>
> > >> Reference:
> > >>
> > >>
> https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> > >> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> > >> [cwiki[.]apache[.]org]
> > >>
> > >> Discussion thread:
> > >>
> > >>
> https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> > >> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> > >> ache.org
> *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> > >>
> > >> Implementation Issue:
> > >>
> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> > >> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> > >> N6AJm4h$ [issues[.]apache[.]org]
> > >>
> > >> Thanks,
> > >> Eron Wright
> > >> StreamNative
> > >>
> >
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-04 Thread Eron Wright
Little update on this, more good discussion over the last few days, and the
FLIP will probably be amended to incorporate idleness.   Voting will remain
open until, let's say, mid-next week.

On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski  wrote:

> I would like to ask you to hold on with counting the votes until I get an
> answer for my one question in the dev mailing list thread (sorry if it was
> already covered somewhere).
>
> Best, Piotrek
>
> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
>
> > +1 (binding)
> >
> > Best,
> > Jark
> >
> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz 
> > wrote:
> >
> > > +1 (binding)
> > >
> > > Best,
> > >
> > > Dawid
> > >
> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> > > > +1 (non-binding)
> > > >
> > > > Thanks Eron, looking forward to seeing this feature soon.
> > > >
> > > > Thanks,
> > > > Brian
> > > >
> > > > -Original Message-
> > > > From: Arvid Heise 
> > > > Sent: Wednesday, June 2, 2021 15:44
> > > > To: dev
> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > > >
> > > >
> > > > [EXTERNAL EMAIL]
> > > >
> > > > +1 (binding)
> > > >
> > > > Thanks Eron for driving this effort; it will open up new exciting use
> > > cases.
> > > >
> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright  > > .invalid>
> > > > wrote:
> > > >
> > > >> After some good discussion about how to enhance the Sink API to
> > > >> process watermarks, I believe we're ready to proceed with a vote.
> > > >> Voting will be open until at least Friday, June 4th, 2021.
> > > >>
> > > >> Reference:
> > > >>
> > > >>
> > https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> > > >>
> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> > > >> [cwiki[.]apache[.]org]
> > > >>
> > > >> Discussion thread:
> > > >>
> > > >>
> > https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> > > >>
> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> > > >> ache.org
> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> > > >>
> > > >> Implementation Issue:
> > > >>
> > https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> > > >>
> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> > > >> N6AJm4h$ [issues[.]apache[.]org]
> > > >>
> > > >> Thanks,
> > > >> Eron Wright
> > > >> StreamNative
> > > >>
> > >
> > >
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-08 Thread Eron Wright
Voting is re-open for FLIP-167 as-is (without idleness support as was the
point of contention).

On Fri, Jun 4, 2021 at 10:45 AM Eron Wright  wrote:

> Little update on this, more good discussion over the last few days, and
> the FLIP will probably be amended to incorporate idleness.   Voting will
> remain open until, let's say, mid-next week.
>
> On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski 
> wrote:
>
>> I would like to ask you to hold on with counting the votes until I get an
>> answer for my one question in the dev mailing list thread (sorry if it was
>> already covered somewhere).
>>
>> Best, Piotrek
>>
>> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
>>
>> > +1 (binding)
>> >
>> > Best,
>> > Jark
>> >
>> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz 
>> > wrote:
>> >
>> > > +1 (binding)
>> > >
>> > > Best,
>> > >
>> > > Dawid
>> > >
>> > > On 03/06/2021 03:50, Zhou, Brian wrote:
>> > > > +1 (non-binding)
>> > > >
>> > > > Thanks Eron, looking forward to seeing this feature soon.
>> > > >
>> > > > Thanks,
>> > > > Brian
>> > > >
>> > > > -Original Message-
>> > > > From: Arvid Heise 
>> > > > Sent: Wednesday, June 2, 2021 15:44
>> > > > To: dev
>> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
>> > > >
>> > > >
>> > > > [EXTERNAL EMAIL]
>> > > >
>> > > > +1 (binding)
>> > > >
>> > > > Thanks Eron for driving this effort; it will open up new exciting
>> use
>> > > cases.
>> > > >
>> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright > > > .invalid>
>> > > > wrote:
>> > > >
>> > > >> After some good discussion about how to enhance the Sink API to
>> > > >> process watermarks, I believe we're ready to proceed with a vote.
>> > > >> Voting will be open until at least Friday, June 4th, 2021.
>> > > >>
>> > > >> Reference:
>> > > >>
>> > > >>
>> > https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
>> > > >>
>> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
>> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
>> > > >> [cwiki[.]apache[.]org]
>> > > >>
>> > > >> Discussion thread:
>> > > >>
>> > > >>
>> > https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
>> > > >>
>> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
>> > > >> ache.org
>> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
>> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
>> > > >>
>> > > >> Implementation Issue:
>> > > >>
>> > https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
>> > > >>
>> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
>> > > >> N6AJm4h$ [issues[.]apache[.]org]
>> > > >>
>> > > >> Thanks,
>> > > >> Eron Wright
>> > > >> StreamNative
>> > > >>
>> > >
>> > >
>> >
>>
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-09 Thread Piotr Nowojski
Thanks for driving this Eron, and sorry for causing the delay.

+1 (binding) from my side

Piotrek

wt., 8 cze 2021 o 23:48 Eron Wright 
napisał(a):

> Voting is re-open for FLIP-167 as-is (without idleness support as was the
> point of contention).
>
> On Fri, Jun 4, 2021 at 10:45 AM Eron Wright 
> wrote:
>
> > Little update on this, more good discussion over the last few days, and
> > the FLIP will probably be amended to incorporate idleness.   Voting will
> > remain open until, let's say, mid-next week.
> >
> > On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski 
> > wrote:
> >
> >> I would like to ask you to hold on with counting the votes until I get
> an
> >> answer for my one question in the dev mailing list thread (sorry if it
> was
> >> already covered somewhere).
> >>
> >> Best, Piotrek
> >>
> >> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
> >>
> >> > +1 (binding)
> >> >
> >> > Best,
> >> > Jark
> >> >
> >> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz  >
> >> > wrote:
> >> >
> >> > > +1 (binding)
> >> > >
> >> > > Best,
> >> > >
> >> > > Dawid
> >> > >
> >> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> >> > > > +1 (non-binding)
> >> > > >
> >> > > > Thanks Eron, looking forward to seeing this feature soon.
> >> > > >
> >> > > > Thanks,
> >> > > > Brian
> >> > > >
> >> > > > -Original Message-
> >> > > > From: Arvid Heise 
> >> > > > Sent: Wednesday, June 2, 2021 15:44
> >> > > > To: dev
> >> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> >> > > >
> >> > > >
> >> > > > [EXTERNAL EMAIL]
> >> > > >
> >> > > > +1 (binding)
> >> > > >
> >> > > > Thanks Eron for driving this effort; it will open up new exciting
> >> use
> >> > > cases.
> >> > > >
> >> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright <
> ewri...@streamnative.io
> >> > > .invalid>
> >> > > > wrote:
> >> > > >
> >> > > >> After some good discussion about how to enhance the Sink API to
> >> > > >> process watermarks, I believe we're ready to proceed with a vote.
> >> > > >> Voting will be open until at least Friday, June 4th, 2021.
> >> > > >>
> >> > > >> Reference:
> >> > > >>
> >> > > >>
> >> >
> https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> >> > > >>
> >> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> >> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> >> > > >> [cwiki[.]apache[.]org]
> >> > > >>
> >> > > >> Discussion thread:
> >> > > >>
> >> > > >>
> >> >
> https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> >> > > >>
> >> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> >> > > >> ache.org
> >> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> >> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> >> > > >>
> >> > > >> Implementation Issue:
> >> > > >>
> >> >
> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> >> > > >>
> >> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> >> > > >> N6AJm4h$ [issues[.]apache[.]org]
> >> > > >>
> >> > > >> Thanks,
> >> > > >> Eron Wright
> >> > > >> StreamNative
> >> > > >>
> >> > >
> >> > >
> >> >
> >>
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-09 Thread jincheng sun
+1 (binding)  // Sorry for the late reply.

Best,
Jincheng


Piotr Nowojski  于2021年6月9日周三 下午10:04写道:

> Thanks for driving this Eron, and sorry for causing the delay.
>
> +1 (binding) from my side
>
> Piotrek
>
> wt., 8 cze 2021 o 23:48 Eron Wright 
> napisał(a):
>
> > Voting is re-open for FLIP-167 as-is (without idleness support as was the
> > point of contention).
> >
> > On Fri, Jun 4, 2021 at 10:45 AM Eron Wright 
> > wrote:
> >
> > > Little update on this, more good discussion over the last few days, and
> > > the FLIP will probably be amended to incorporate idleness.   Voting
> will
> > > remain open until, let's say, mid-next week.
> > >
> > > On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski 
> > > wrote:
> > >
> > >> I would like to ask you to hold on with counting the votes until I get
> > an
> > >> answer for my one question in the dev mailing list thread (sorry if it
> > was
> > >> already covered somewhere).
> > >>
> > >> Best, Piotrek
> > >>
> > >> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
> > >>
> > >> > +1 (binding)
> > >> >
> > >> > Best,
> > >> > Jark
> > >> >
> > >> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz <
> dwysakow...@apache.org
> > >
> > >> > wrote:
> > >> >
> > >> > > +1 (binding)
> > >> > >
> > >> > > Best,
> > >> > >
> > >> > > Dawid
> > >> > >
> > >> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> > >> > > > +1 (non-binding)
> > >> > > >
> > >> > > > Thanks Eron, looking forward to seeing this feature soon.
> > >> > > >
> > >> > > > Thanks,
> > >> > > > Brian
> > >> > > >
> > >> > > > -Original Message-
> > >> > > > From: Arvid Heise 
> > >> > > > Sent: Wednesday, June 2, 2021 15:44
> > >> > > > To: dev
> > >> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > >> > > >
> > >> > > >
> > >> > > > [EXTERNAL EMAIL]
> > >> > > >
> > >> > > > +1 (binding)
> > >> > > >
> > >> > > > Thanks Eron for driving this effort; it will open up new
> exciting
> > >> use
> > >> > > cases.
> > >> > > >
> > >> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright <
> > ewri...@streamnative.io
> > >> > > .invalid>
> > >> > > > wrote:
> > >> > > >
> > >> > > >> After some good discussion about how to enhance the Sink API to
> > >> > > >> process watermarks, I believe we're ready to proceed with a
> vote.
> > >> > > >> Voting will be open until at least Friday, June 4th, 2021.
> > >> > > >>
> > >> > > >> Reference:
> > >> > > >>
> > >> > > >>
> > >> >
> > https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> > >> > > >>
> > >> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> > >> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> > >> > > >> [cwiki[.]apache[.]org]
> > >> > > >>
> > >> > > >> Discussion thread:
> > >> > > >>
> > >> > > >>
> > >> >
> > https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> > >> > > >>
> > >> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> > >> > > >> ache.org
> > >> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> > >> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> > >> > > >>
> > >> > > >> Implementation Issue:
> > >> > > >>
> > >> >
> > https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> > >> > > >>
> > >> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> > >> > > >> N6AJm4h$ [issues[.]apache[.]org]
> > >> > > >>
> > >> > > >> Thanks,
> > >> > > >> Eron Wright
> > >> > > >> StreamNative
> > >> > > >>
> > >> > >
> > >> > >
> > >> >
> > >>
> > >
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-09 Thread Tzu-Li (Gordon) Tai
+1

On Thu, Jun 10, 2021 at 9:04 AM jincheng sun 
wrote:

> +1 (binding)  // Sorry for the late reply.
>
> Best,
> Jincheng
>
>
> Piotr Nowojski  于2021年6月9日周三 下午10:04写道:
>
> > Thanks for driving this Eron, and sorry for causing the delay.
> >
> > +1 (binding) from my side
> >
> > Piotrek
> >
> > wt., 8 cze 2021 o 23:48 Eron Wright 
> > napisał(a):
> >
> > > Voting is re-open for FLIP-167 as-is (without idleness support as was
> the
> > > point of contention).
> > >
> > > On Fri, Jun 4, 2021 at 10:45 AM Eron Wright 
> > > wrote:
> > >
> > > > Little update on this, more good discussion over the last few days,
> and
> > > > the FLIP will probably be amended to incorporate idleness.   Voting
> > will
> > > > remain open until, let's say, mid-next week.
> > > >
> > > > On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski 
> > > > wrote:
> > > >
> > > >> I would like to ask you to hold on with counting the votes until I
> get
> > > an
> > > >> answer for my one question in the dev mailing list thread (sorry if
> it
> > > was
> > > >> already covered somewhere).
> > > >>
> > > >> Best, Piotrek
> > > >>
> > > >> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
> > > >>
> > > >> > +1 (binding)
> > > >> >
> > > >> > Best,
> > > >> > Jark
> > > >> >
> > > >> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz <
> > dwysakow...@apache.org
> > > >
> > > >> > wrote:
> > > >> >
> > > >> > > +1 (binding)
> > > >> > >
> > > >> > > Best,
> > > >> > >
> > > >> > > Dawid
> > > >> > >
> > > >> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> > > >> > > > +1 (non-binding)
> > > >> > > >
> > > >> > > > Thanks Eron, looking forward to seeing this feature soon.
> > > >> > > >
> > > >> > > > Thanks,
> > > >> > > > Brian
> > > >> > > >
> > > >> > > > -Original Message-
> > > >> > > > From: Arvid Heise 
> > > >> > > > Sent: Wednesday, June 2, 2021 15:44
> > > >> > > > To: dev
> > > >> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > > >> > > >
> > > >> > > >
> > > >> > > > [EXTERNAL EMAIL]
> > > >> > > >
> > > >> > > > +1 (binding)
> > > >> > > >
> > > >> > > > Thanks Eron for driving this effort; it will open up new
> > exciting
> > > >> use
> > > >> > > cases.
> > > >> > > >
> > > >> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright <
> > > ewri...@streamnative.io
> > > >> > > .invalid>
> > > >> > > > wrote:
> > > >> > > >
> > > >> > > >> After some good discussion about how to enhance the Sink API
> to
> > > >> > > >> process watermarks, I believe we're ready to proceed with a
> > vote.
> > > >> > > >> Voting will be open until at least Friday, June 4th, 2021.
> > > >> > > >>
> > > >> > > >> Reference:
> > > >> > > >>
> > > >> > > >>
> > > >> >
> > > https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> > > >> > > >>
> > > >>
> y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> > > >> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> > > >> > > >> [cwiki[.]apache[.]org]
> > > >> > > >>
> > > >> > > >> Discussion thread:
> > > >> > > >>
> > > >> > > >>
> > > >> >
> > > https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> > > >> > > >>
> > > >>
> e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> > > >> > > >> ache.org
> > > >> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> > > >> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> > > >> > > >>
> > > >> > > >> Implementation Issue:
> > > >> > > >>
> > > >> >
> > > https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> > > >> > > >>
> > > >>
> K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> > > >> > > >> N6AJm4h$ [issues[.]apache[.]org]
> > > >> > > >>
> > > >> > > >> Thanks,
> > > >> > > >> Eron Wright
> > > >> > > >> StreamNative
> > > >> > > >>
> > > >> > >
> > > >> > >
> > > >> >
> > > >>
> > > >
> > >
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-10 Thread Till Rohrmann
+1,

Cheers,
Till

On Thu, Jun 10, 2021 at 4:59 AM Tzu-Li (Gordon) Tai 
wrote:

> +1
>
> On Thu, Jun 10, 2021 at 9:04 AM jincheng sun 
> wrote:
>
> > +1 (binding)  // Sorry for the late reply.
> >
> > Best,
> > Jincheng
> >
> >
> > Piotr Nowojski  于2021年6月9日周三 下午10:04写道:
> >
> > > Thanks for driving this Eron, and sorry for causing the delay.
> > >
> > > +1 (binding) from my side
> > >
> > > Piotrek
> > >
> > > wt., 8 cze 2021 o 23:48 Eron Wright 
> > > napisał(a):
> > >
> > > > Voting is re-open for FLIP-167 as-is (without idleness support as was
> > the
> > > > point of contention).
> > > >
> > > > On Fri, Jun 4, 2021 at 10:45 AM Eron Wright  >
> > > > wrote:
> > > >
> > > > > Little update on this, more good discussion over the last few days,
> > and
> > > > > the FLIP will probably be amended to incorporate idleness.   Voting
> > > will
> > > > > remain open until, let's say, mid-next week.
> > > > >
> > > > > On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski <
> pnowoj...@apache.org>
> > > > > wrote:
> > > > >
> > > > >> I would like to ask you to hold on with counting the votes until I
> > get
> > > > an
> > > > >> answer for my one question in the dev mailing list thread (sorry
> if
> > it
> > > > was
> > > > >> already covered somewhere).
> > > > >>
> > > > >> Best, Piotrek
> > > > >>
> > > > >> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
> > > > >>
> > > > >> > +1 (binding)
> > > > >> >
> > > > >> > Best,
> > > > >> > Jark
> > > > >> >
> > > > >> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz <
> > > dwysakow...@apache.org
> > > > >
> > > > >> > wrote:
> > > > >> >
> > > > >> > > +1 (binding)
> > > > >> > >
> > > > >> > > Best,
> > > > >> > >
> > > > >> > > Dawid
> > > > >> > >
> > > > >> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> > > > >> > > > +1 (non-binding)
> > > > >> > > >
> > > > >> > > > Thanks Eron, looking forward to seeing this feature soon.
> > > > >> > > >
> > > > >> > > > Thanks,
> > > > >> > > > Brian
> > > > >> > > >
> > > > >> > > > -Original Message-
> > > > >> > > > From: Arvid Heise 
> > > > >> > > > Sent: Wednesday, June 2, 2021 15:44
> > > > >> > > > To: dev
> > > > >> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > > > >> > > >
> > > > >> > > >
> > > > >> > > > [EXTERNAL EMAIL]
> > > > >> > > >
> > > > >> > > > +1 (binding)
> > > > >> > > >
> > > > >> > > > Thanks Eron for driving this effort; it will open up new
> > > exciting
> > > > >> use
> > > > >> > > cases.
> > > > >> > > >
> > > > >> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright <
> > > > ewri...@streamnative.io
> > > > >> > > .invalid>
> > > > >> > > > wrote:
> > > > >> > > >
> > > > >> > > >> After some good discussion about how to enhance the Sink
> API
> > to
> > > > >> > > >> process watermarks, I believe we're ready to proceed with a
> > > vote.
> > > > >> > > >> Voting will be open until at least Friday, June 4th, 2021.
> > > > >> > > >>
> > > > >> > > >> Reference:
> > > > >> > > >>
> > > > >> > > >>
> > > > >> >
> > > >
> https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> > > > >> > > >>
> > > > >>
> > y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> > > > >> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> > > > >> > > >> [cwiki[.]apache[.]org]
> > > > >> > > >>
> > > > >> > > >> Discussion thread:
> > > > >> > > >>
> > > > >> > > >>
> > > > >> >
> > > >
> https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> > > > >> > > >>
> > > > >>
> > e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> > > > >> > > >> ache.org
> > > > >> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> > > > >> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> > > > >> > > >>
> > > > >> > > >> Implementation Issue:
> > > > >> > > >>
> > > > >> >
> > > >
> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> > > > >> > > >>
> > > > >>
> > K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> > > > >> > > >> N6AJm4h$ [issues[.]apache[.]org]
> > > > >> > > >>
> > > > >> > > >> Thanks,
> > > > >> > > >> Eron Wright
> > > > >> > > >> StreamNative
> > > > >> > > >>
> > > > >> > >
> > > > >> > >
> > > > >> >
> > > > >>
> > > > >
> > > >
> > >
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-10 Thread Arvid Heise
Reconfirming my +1 (binding).

On Thu, Jun 10, 2021 at 12:14 PM Till Rohrmann  wrote:

> +1,
>
> Cheers,
> Till
>
> On Thu, Jun 10, 2021 at 4:59 AM Tzu-Li (Gordon) Tai 
> wrote:
>
> > +1
> >
> > On Thu, Jun 10, 2021 at 9:04 AM jincheng sun 
> > wrote:
> >
> > > +1 (binding)  // Sorry for the late reply.
> > >
> > > Best,
> > > Jincheng
> > >
> > >
> > > Piotr Nowojski  于2021年6月9日周三 下午10:04写道:
> > >
> > > > Thanks for driving this Eron, and sorry for causing the delay.
> > > >
> > > > +1 (binding) from my side
> > > >
> > > > Piotrek
> > > >
> > > > wt., 8 cze 2021 o 23:48 Eron Wright  .invalid>
> > > > napisał(a):
> > > >
> > > > > Voting is re-open for FLIP-167 as-is (without idleness support as
> was
> > > the
> > > > > point of contention).
> > > > >
> > > > > On Fri, Jun 4, 2021 at 10:45 AM Eron Wright <
> ewri...@streamnative.io
> > >
> > > > > wrote:
> > > > >
> > > > > > Little update on this, more good discussion over the last few
> days,
> > > and
> > > > > > the FLIP will probably be amended to incorporate idleness.
>  Voting
> > > > will
> > > > > > remain open until, let's say, mid-next week.
> > > > > >
> > > > > > On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski <
> > pnowoj...@apache.org>
> > > > > > wrote:
> > > > > >
> > > > > >> I would like to ask you to hold on with counting the votes
> until I
> > > get
> > > > > an
> > > > > >> answer for my one question in the dev mailing list thread (sorry
> > if
> > > it
> > > > > was
> > > > > >> already covered somewhere).
> > > > > >>
> > > > > >> Best, Piotrek
> > > > > >>
> > > > > >> czw., 3 cze 2021 o 16:12 Jark Wu  napisał(a):
> > > > > >>
> > > > > >> > +1 (binding)
> > > > > >> >
> > > > > >> > Best,
> > > > > >> > Jark
> > > > > >> >
> > > > > >> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz <
> > > > dwysakow...@apache.org
> > > > > >
> > > > > >> > wrote:
> > > > > >> >
> > > > > >> > > +1 (binding)
> > > > > >> > >
> > > > > >> > > Best,
> > > > > >> > >
> > > > > >> > > Dawid
> > > > > >> > >
> > > > > >> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> > > > > >> > > > +1 (non-binding)
> > > > > >> > > >
> > > > > >> > > > Thanks Eron, looking forward to seeing this feature soon.
> > > > > >> > > >
> > > > > >> > > > Thanks,
> > > > > >> > > > Brian
> > > > > >> > > >
> > > > > >> > > > -Original Message-
> > > > > >> > > > From: Arvid Heise 
> > > > > >> > > > Sent: Wednesday, June 2, 2021 15:44
> > > > > >> > > > To: dev
> > > > > >> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > > > > >> > > >
> > > > > >> > > >
> > > > > >> > > > [EXTERNAL EMAIL]
> > > > > >> > > >
> > > > > >> > > > +1 (binding)
> > > > > >> > > >
> > > > > >> > > > Thanks Eron for driving this effort; it will open up new
> > > > exciting
> > > > > >> use
> > > > > >> > > cases.
> > > > > >> > > >
> > > > > >> > > > On Tue, Jun 1, 2021 at 7:17 PM Eron Wright <
> > > > > ewri...@streamnative.io
> > > > > >> > > .invalid>
> > > > > >> > > > wrote:
> > > > > >> > > >
> > > > > >> > > >> After some good discussion about how to enhance the Sink
> > API
> > > to
> > > > > >> > > >> process watermarks, I believe we're ready to proceed
> with a
> > > > vote.
> > > > > >> > > >> Voting will be open until at least Friday, June 4th,
> 2021.
> > > > > >> > > >>
> > > > > >> > > >> Reference:
> > > > > >> > > >>
> > > > > >> > > >>
> > > > > >> >
> > > > >
> > https://urldefense.com/v3/__https://cwiki.apache.org/confluence/displa
> > > > > >> > > >>
> > > > > >>
> > > y/FLINK/FLIP-167*3A*Watermarks*for*Sink*API__;JSsrKys!!LpKI!zkBBhuqEEi
> > > > > >> > > >> fxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-GCBb-PTq$
> > > > > >> > > >> [cwiki[.]apache[.]org]
> > > > > >> > > >>
> > > > > >> > > >> Discussion thread:
> > > > > >> > > >>
> > > > > >> > > >>
> > > > > >> >
> > > > >
> > https://urldefense.com/v3/__https://lists.apache.org/thread.html/r5194
> > > > > >> > > >>
> > > > > >>
> > > e1cf157d1fd5ba7ca9b567cb01723bd582aa12dda57d25bca37e*40*3Cdev.flink.ap
> > > > > >> > > >> ache.org
> > > > > >> > *3E__;JSUl!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viF
> > > > > >> > > >> WXPLul-GJXlxwqN$ [lists[.]apache[.]org]
> > > > > >> > > >>
> > > > > >> > > >> Implementation Issue:
> > > > > >> > > >>
> > > > > >> >
> > > > >
> > https://urldefense.com/v3/__https://issues.apache.org/jira/browse/FLIN
> > > > > >> > > >>
> > > > > >>
> > > K-22700__;!!LpKI!zkBBhuqEEifxF_fDQqAjqsbuWWFmnAvwRfEAWxeC63viFWXPLul-G
> > > > > >> > > >> N6AJm4h$ [issues[.]apache[.]org]
> > > > > >> > > >>
> > > > > >> > > >> Thanks,
> > > > > >> > > >> Eron Wright
> > > > > >> > > >> StreamNative
> > > > > >> > > >>
> > > > > >> > >
> > > > > >> > >
> > > > > >> >
> > > > > >>
> > > > > >
> > > > >
> > > >
> > >
> >
>


Re: [VOTE] Watermark propagation with Sink API

2021-06-10 Thread Eron Wright
We have 7 binding votes and no objections, so FLIP-167 passed.

Here's the implementation issue and PR which is ready for review.
https://issues.apache.org/jira/browse/FLINK-22700
https://github.com/apache/flink/pull/15950

Thank-you everyone.

On Thu, Jun 10, 2021 at 3:32 AM Arvid Heise  wrote:

> Reconfirming my +1 (binding).
>
> On Thu, Jun 10, 2021 at 12:14 PM Till Rohrmann 
> wrote:
>
> > +1,
> >
> > Cheers,
> > Till
> >
> > On Thu, Jun 10, 2021 at 4:59 AM Tzu-Li (Gordon) Tai  >
> > wrote:
> >
> > > +1
> > >
> > > On Thu, Jun 10, 2021 at 9:04 AM jincheng sun  >
> > > wrote:
> > >
> > > > +1 (binding)  // Sorry for the late reply.
> > > >
> > > > Best,
> > > > Jincheng
> > > >
> > > >
> > > > Piotr Nowojski  于2021年6月9日周三 下午10:04写道:
> > > >
> > > > > Thanks for driving this Eron, and sorry for causing the delay.
> > > > >
> > > > > +1 (binding) from my side
> > > > >
> > > > > Piotrek
> > > > >
> > > > > wt., 8 cze 2021 o 23:48 Eron Wright  > .invalid>
> > > > > napisał(a):
> > > > >
> > > > > > Voting is re-open for FLIP-167 as-is (without idleness support as
> > was
> > > > the
> > > > > > point of contention).
> > > > > >
> > > > > > On Fri, Jun 4, 2021 at 10:45 AM Eron Wright <
> > ewri...@streamnative.io
> > > >
> > > > > > wrote:
> > > > > >
> > > > > > > Little update on this, more good discussion over the last few
> > days,
> > > > and
> > > > > > > the FLIP will probably be amended to incorporate idleness.
> >  Voting
> > > > > will
> > > > > > > remain open until, let's say, mid-next week.
> > > > > > >
> > > > > > > On Thu, Jun 3, 2021 at 8:00 AM Piotr Nowojski <
> > > pnowoj...@apache.org>
> > > > > > > wrote:
> > > > > > >
> > > > > > >> I would like to ask you to hold on with counting the votes
> > until I
> > > > get
> > > > > > an
> > > > > > >> answer for my one question in the dev mailing list thread
> (sorry
> > > if
> > > > it
> > > > > > was
> > > > > > >> already covered somewhere).
> > > > > > >>
> > > > > > >> Best, Piotrek
> > > > > > >>
> > > > > > >> czw., 3 cze 2021 o 16:12 Jark Wu 
> napisał(a):
> > > > > > >>
> > > > > > >> > +1 (binding)
> > > > > > >> >
> > > > > > >> > Best,
> > > > > > >> > Jark
> > > > > > >> >
> > > > > > >> > On Thu, 3 Jun 2021 at 21:34, Dawid Wysakowicz <
> > > > > dwysakow...@apache.org
> > > > > > >
> > > > > > >> > wrote:
> > > > > > >> >
> > > > > > >> > > +1 (binding)
> > > > > > >> > >
> > > > > > >> > > Best,
> > > > > > >> > >
> > > > > > >> > > Dawid
> > > > > > >> > >
> > > > > > >> > > On 03/06/2021 03:50, Zhou, Brian wrote:
> > > > > > >> > > > +1 (non-binding)
> > > > > > >> > > >
> > > > > > >> > > > Thanks Eron, looking forward to seeing this feature
> soon.
> > > > > > >> > > >
> > > > > > >> > > > Thanks,
> > > > > > >> > > > Brian
> > > > > > >> > > >
> > > > > > >> > > > -Original Message-
> > > > > > >> > > > From: Arvid Heise 
> > > > > > >> > > > Sent: Wednesday, June 2, 2021 15:44
> > > > > > >> > > > To: dev
> > > > > > >> > > > Subject: Re: [VOTE] Watermark propagation with Sink API
> > > > > > >> > > >
> > > > > >