gt; > > all Runners to be
> > > able to support delaying bundles. Flink supports
> > cycles
> > > and thus
> > > approach #2 would also be applicable and could be
> > us
:boyu...@google.com>
<mailto:boyu...@google.com <mailto:boyu...@google.com>>
> > <mailto:boyu...@google.com
<mailto:boyu...@google.com>
> <mailto:boyu...@google.com
<mailto:boyu...@google.com>>>&
> > > Thanks Boyuan, I left a few comments.
> > >
> > > On Mon, Oct 5, 2020 at 11:12 AM Boyuan Zhang
> > mailto:boyu...@google.com>
> > > <mailto:boyu...@
oogle.com
<mailto:boyu...@google.com>>> wrote:
>
> Hi team,
>
> I'm looking at adding self-checkpoint support to
portable Flink
> runner(BEAM-10940
> <ht
t; >
>>> > On Mon, Oct 5, 2020 at 11:12 AM Boyuan Zhang >> > <mailto:boyu...@google.com>> wrote:
>>> >
>>> > Hi team,
>>> >
>>> > I'm looking at adding self-checkpoint support to portable Flink
>>> >
applicable and could be used to implement
>> dynamic splitting.
>>
>> -Max
>>
>> On 05.10.20 23:13, Luke Cwik wrote:
>> > Thanks Boyuan, I left a few comments.
>> >
>> > On Mon, Oct 5, 2020 at 11:12 AM Boyuan Zhang > > <mailto:bo
.
-Max
On 05.10.20 23:13, Luke Cwik wrote:
Thanks Boyuan, I left a few comments.
On Mon, Oct 5, 2020 at 11:12 AM Boyuan Zhang <mailto:boyu...@google.com>> wrote:
Hi team,
I'm looking at adding self-checkpoint support to portable Flink
runner(BEAM-10940
Thanks Boyuan, I left a few comments.
On Mon, Oct 5, 2020 at 11:12 AM Boyuan Zhang wrote:
> Hi team,
>
> I'm looking at adding self-checkpoint support to portable Flink runner(
> BEAM-10940 <https://issues.apache.org/jira/browse/BEAM-10940>) for both
> batch and st
