eave run() after you
>>> ingested all data.
>>>
>>> Note, that Flink won't wait for all processing time timers but will
>>> immediately shutdown the program after the last in-flight record was
>>> processed.
>>> Event-time timers will
t; but I am not sure if I can use it in my use case.
>
> --
> Dhruv Kumar
> PhD Candidate
> Department of Computer Science and Engineering
> University of Minnesota
> www.dhruvkumar.me <http://www.dhruvkumar.me/>
>
>&
> On May 7, 2018, at 06:18, Dhruv Kumar <gargdhru...@gmail.com> wrote:
>
> Hi
>
> Is there a way I can capture the end of stream signal for streams which
> are replayed from historical data? I need the end of stream signal to tell
> the Flink program to finish its execu
and Engineering
University of Minnesota
www.dhruvkumar.me
> On May 7, 2018, at 06:18, Dhruv Kumar <gargdhru...@gmail.com> wrote:
>
> Hi
>
> Is there a way I can capture the end of stream signal for streams which are
> replayed from historical data? I need the end of stream sig
Hi
Is there a way I can capture the end of stream signal for streams which are
replayed from historical data? I need the end of stream signal to tell the
Flink program to finish its execution.
Below is the use case in detail:
1. An independent log replayer program sends the records to a socket
