--
Narendra Joshi
not
find a satisfying reason for increase in latency with state size.
Best,
Narendra
Narendra Joshi
On 29 Oct 2017 15:04, "Sofer, Tovi" wrote:
> Hi all,
>
>
>
> In our application we have a requirement to very low latency, preferably
> less than 5ms.
>
> We wer
rg/projects/flink/flink-docs-release-1.3/ops/
> state_backends.html
> [3] https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/stream/
> checkpointing.html
> [4] https://www.youtube.com/watch?
> v=dWQ24wERItM&index=36&list=PLDX4T_cnKjD0JeULl1X6iTn7VIkDeYX_X
&
riers for all inputs for the next
checkpoint. What will happen in this case if no concurrent checkpoints
are allowed (i.e. the default value is used)? What will happen if
concurrent checkpoints are allowed?
Thanks,
Narendra Joshi
between `processElement` and `onTimer`?
4. Is there a plan for moving from Scheduled Threadpool Executor to
using timing wheels for timeout?
If there is any other information that you need, please let me know.
On Tue, Sep 19, 2017 at 10:37 PM, Narendra Joshi wrote:
> The number of timers is about
The number of timers is about 400 per second. We have observed that onTimer
calls are delayed only when the number of scheduled timers starts
increasing from a minima. It would be great if you can share pointers to
code I can look at to understand it better. :)
Narendra Joshi
On 14 Sep 2017 16:04
` starve `onTimer` calls?
--
Narendra Joshi
