Kx Systems aka Q or KDB
-Original Message-
From: Yi Pan [mailto:nickpa...@gmail.com]
Sent: 06 September 2016 17:40
To: dev@samza.apache.org
Subject: Re: checkpoint on flush of system producer
Hi, Jarrad,
Yes! You have found your answer! Looking forward to your implementation of
Hi, Jarrad,
Yes! You have found your answer! Looking forward to your implementation of
SystemProducer. Just curious, what's the target output system that you are
writing to?
-Yi
On Tue, Sep 6, 2016 at 9:01 AM, Jarrad, Ken
wrote:
> I think I have discovered the answer to my question. Hopefully
I think I have discovered the answer to my question. Hopefully someone can
confirm my understanding.
The 'flush' method of my SystemProducer will be invoked prior to the
checkpoint. Thus the checkpoint cannot get ahead of the SystemProducer. Thus
the guarantee is 'at least once'.
I will do my
