[
https://issues.apache.org/jira/browse/SAMZA-1715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yi Pan (Data Infrastructure) reassigned SAMZA-1715:
---------------------------------------------------
Assignee: Yi Pan (Data Infrastructure)
> Unit test for Kafka admin deletedMessagesCalled() fail
> ------------------------------------------------------
>
> Key: SAMZA-1715
> URL: https://issues.apache.org/jira/browse/SAMZA-1715
> Project: Samza
> Issue Type: Improvement
> Reporter: Yi Pan (Data Infrastructure)
> Assignee: Yi Pan (Data Infrastructure)
> Priority: Major
> Fix For: 0.15
>
>
> There is a intermittent failure in
> TestRepartitionJoinWindowApp.testRepartitionJoinWindowAppWithoutDeletionOnCommit()
> due to the flag deleteMessagesCalled is *always* set and
> SystemAdmin.deleteMessages() is always called in TaskInstance.commit().
> Hence, when the auto-commit is triggered in the test, the assertion in the
> unit test will fail.
> The fix is to set the deleteMessagesCalled flag *only* when the actual delete
> action is invoked.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
