Hi,
I think the problem is that the Trigger only uses processing time to determine
when to trigger. If the job shuts down (which happens when the sources shut
down and the whole pipeline is flushed) pending processing-time triggers are
not fired.
You can use the fact that when sources shutdown
Hi,
If your could give us a look at your custom Trigger we might be able to figure
out what’s going on.
Best,
Aljoscha
> On 22. May 2017, at 09:06, Samim Ahmed wrote:
>
> Hello All,
>
> Hope you are doing well..
>
> Myself Samim and I am working of POC(proof of concept) for a project. In th
Hello All,
Hope you are doing well..
Myself Samim and I am working of POC(proof of concept) for a project. In
this project we are using Apache Flink to process the stream data and find
the required pattern and finally dump those patterns in DB.
So to implement this we have used the global w
