[
https://issues.apache.org/jira/browse/KAFKA-773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13586703#comment-13586703
]
Neha Narkhede commented on KAFKA-773:
-------------------------------------
Thanks for the patch. Adding a sleep seems to fix it, but will be timing
dependent. How about using waitUntilTrue to check for the highwatermark values
? It will be faster than a sleep since at most times it will finish quickly.
> kafka.integration.PrimitiveApiTest fails intermittently
> -------------------------------------------------------
>
> Key: KAFKA-773
> URL: https://issues.apache.org/jira/browse/KAFKA-773
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8
> Reporter: Swapnil Ghike
> Assignee: Swapnil Ghike
> Priority: Blocker
> Attachments: kafka-773.patch
>
>
> junit.framework.AssertionFailedError:
> Expected :List(a_test3, b_test3)
> Actual :List()
> <Click to see difference>
> at
> kafka.integration.PrimitiveApiTest$$anonfun$testPipelinedProduceRequests$6.apply(PrimitiveApiTest.scala:340)
> at
> kafka.integration.PrimitiveApiTest$$anonfun$testPipelinedProduceRequests$6.apply(PrimitiveApiTest.scala:338)
> at
> scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
> at scala.collection.immutable.List.foreach(List.scala:45)
> at
> kafka.integration.PrimitiveApiTest.testPipelinedProduceRequests(PrimitiveApiTest.scala:338)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> at
> org.junit.internal.runners.OldTestClassRunner.run(OldTestClassRunner.java:35)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:121)
> at
> com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:76)
> at
> com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:195)
> at
> com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:63)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> at com.intellij.rt.execution.application.AppMain.main(AppMain.java:120)
> Process finished with exit code 255
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
