flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hermann Gábor <reckone...@gmail.com>
Subject Re: Events not received
Date Wed, 11 Feb 2015 10:23:12 GMT
In our case we are actually waiting for some kind of acknowledgement events,
so it is easily verifiable if there are any further events. We check
whether everything
has been acknowledged.

On Tue Feb 10 2015 at 9:42:14 AM Ufuk Celebi <uce@apache.org> wrote:

>
> On 10 Feb 2015, at 02:13, Hermann Gábor <reckoner42@gmail.com> wrote:
>
> > Hey Ufuk,
> >
> > Thanks for the fast reply and fix! It's working now :)
> >
> > Unfortunately the "other side" of the AbstractInvokable lifecycle is
> > causing a bit of a trouble,
> > as the AbstractInvokable does not wait for possible events before
> > finishing, and it throws an
> > IllegalStateException: Tried to send task event to producer before
> > requesting a queue.
> > exception when trying to send an event after the task finished.
> >
> > For now we have a workaround to this (the above fixed problem was the
> > trickier one for us) in a higher level, but it would be
> > nice if the events adjusted to the AbstractInvokable lifecycle, i.e. the
> > AbstractInvokable would be kept up
> > until all Readers/Writers that subscribed to events are shut down.
>
> OK, good to hear that it is working. The producer and consumer tasks used
> to wait for each other before they finished. With iterations and superstep
> events, the iteration task logic ensures that tasks don't finish
> prematurely.
>
> How are you doing it? Waiting a certain number of events?

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message