[
https://issues.apache.org/jira/browse/SAMZA-224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14017949#comment-14017949
]
Chris Riccomini commented on SAMZA-224:
---------------------------------------
I don't think the blame lies with SystemStreamMetadata, OffsetManager, or
BrokerProxy. The code is behaving as expected. It's the test that's at fault. I
believe I introduced this regression in order to test SAMZA-142. I think we can:
# fix this by moving the SAMZA-142 validation into a separate test, and
changing systems.kafka.consumer.auto.offset.reset to be "smallest", as it was
before.
# inject a few messages in the input stream so that auto.offset.reset is not
used for the input stream--a valid offset would exist in SystemStreamMetadata.
# Somehow making sure that the broker fully starts up before we send our test
messages.
I'm not quite sure how to do (3) at first glance. We might be able to hack
something, but (1) seems like the cleanest fix. I was piggy backing off of this
test to test SAMZA-142, but it's interfering with other validation, so I think
we should just split out the validation into two different tests.
> TestStatefulTask.testShouldStartAndRestore fails intermittently
> ---------------------------------------------------------------
>
> Key: SAMZA-224
> URL: https://issues.apache.org/jira/browse/SAMZA-224
> Project: Samza
> Issue Type: Bug
> Components: test
> Affects Versions: 0.6.0
> Reporter: Martin Kleppmann
> Assignee: Martin Kleppmann
> Fix For: 0.7.0
>
>
> [~closeuris] reported the following issue on SAMZA-185. I'm now
> intermittently seeing this problem too, so I'm opening a new issue for it (as
> I'm not sure the issue has anything to do with the Kafka 0.8.1 upgrade).
> {noformat}
> org.apache.samza.test.integration.TestStatefulTask >
> testShouldStartAndRestore FAILED
> java.lang.AssertionError at TestStatefulTask.scala:356
> 2 tests completed, 1 failed
> :samza-test_2.10:test FAILED
> {noformat}
> Logs provided by Yan (mine look similar):
> Failed tests: http://pastebin.com/3nEDw9jC
> Standard output: http://pastebin.com/20vZbk7c
> Standard error: http://pastebin.com/gU6cTNAr
--
This message was sent by Atlassian JIRA
(v6.2#6252)
