18:32
> To: user@flink.apache.org
> Subject: Re: Making batches of small messages
>
> Hi,
>
> I think this is a case for the ProcessFunction that was recently added and
> will be included in Flink 1.2.
> ProcessFunction allows to register timers (so the 5 secs timeout c
Thanks,
We are waiting for the 1.2 release eagerly ☺
From: Fabian Hueske [mailto:fhue...@gmail.com]
Sent: mercredi 11 janvier 2017 18:32
To: user@flink.apache.org
Subject: Re: Making batches of small messages
Hi,
I think this is a case for the ProcessFunction that was recently added and will
Hi,
I think this is a case for the ProcessFunction that was recently added and
will be included in Flink 1.2.
ProcessFunction allows to register timers (so the 5 secs timeout can be
addressed). You can maintain the fault tolerance guarantees if you collect
the records in managed state. That way th
