[Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

[Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

Eron Wright-2
Hello,

We see an issue with the use of `MasterTriggerRestoreHook` to synchronize
the state of a source function with that of an external system.  I'd like
the fix to be considered for 1.5.

There's a patch ready:
https://github.com/apache/flink/pull/5427

Thanks!
Reply | Threaded
Open this post in threaded view
|

Re: [Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

Stephan Ewen
I see that this is an important issue.

Will try to review this soon. Till and me are the only ones that worked in
this, and unfortunately is out this week and the next, and I am travelling
a lot, being a bit swamped with conferences. Will try to get to that asap...

On Wed, Apr 18, 2018 at 12:43 AM, Eron Wright <[hidden email]> wrote:

> Hello,
>
> We see an issue with the use of `MasterTriggerRestoreHook` to synchronize
> the state of a source function with that of an external system.  I'd like
> the fix to be considered for 1.5.
>
> There's a patch ready:
> https://github.com/apache/flink/pull/5427
>
> Thanks!
>
Reply | Threaded
Open this post in threaded view
|

Re: [Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

Fabian Hueske-2
Should we raise FLINK-8533 as a blocker for 1.5.0?

@Eron Can you post this in the "[DISCUSS] Releasing Flink 1.5.0" thread to
make sure it doesn't get lost?

Thanks,
Fabian

2018-04-18 13:05 GMT+02:00 Stephan Ewen <[hidden email]>:

> I see that this is an important issue.
>
> Will try to review this soon. Till and me are the only ones that worked in
> this, and unfortunately is out this week and the next, and I am travelling
> a lot, being a bit swamped with conferences. Will try to get to that
> asap...
>
> On Wed, Apr 18, 2018 at 12:43 AM, Eron Wright <[hidden email]>
> wrote:
>
> > Hello,
> >
> > We see an issue with the use of `MasterTriggerRestoreHook` to synchronize
> > the state of a source function with that of an external system.  I'd like
> > the fix to be considered for 1.5.
> >
> > There's a patch ready:
> > https://github.com/apache/flink/pull/5427
> >
> > Thanks!
> >
>