You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@apex.apache.org by Hitesh Kapoor <hi...@datatorrent.com> on 2016/10/14 14:57:31 UTC

(APEXMALHAR-2291) Exactly-once processing not working correctly for JdbcPOJOInsertOutputOperator

Hi All,

It is observed that the exactly-once processing is not working correctly.
The reason for this is that when the operator crashes, it comes back and
inserts data again for non-checkpointed windows.
Hence redundant rows are added in the table. The fix is simple and
suggested by Sandeep is to add a check in endWindow() not to update the
meta data in output store.
I will do the required code change add a corresponding unit test case and
open PR (if there are no objections).

Regards,
Hitesh