[
https://issues.apache.org/jira/browse/KAFKA-773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Swapnil Ghike updated KAFKA-773:
--------------------------------
Attachment: kafka-773.patch
This test fails when highWatermark for a partition is updated after its log
segment is read. Doesn't look like a real issue, we can fix the test by making
the main thread wait until all highwatermarks have been updated.
Some debugging:
Highwatermark for topic test4 partition 0 updated to 2
Highwatermark for topic test1 partition 0 updated to 2
Highwatermark for topic test2 partition 0 updated to 2
Reading 10000 bytes from offset 0 in log test2-0 of length 76 bytes, maxOffset
= 2
Attempt to read with a maximum offset (2) less than the start offset (0).
inside logsegment messageset sizeinBytes = 76 length = 76 startposition = 0
Reading 10000 bytes from offset 0 in log test3-0 of length 76 bytes, maxOffset
= 0
Attempt to read with a maximum offset (0) less than the start offset (0).
inside logsegment messageset sizeinBytes = 76 length = 0 startposition = 0
Reading 10000 bytes from offset 0 in log test4-0 of length 76 bytes, maxOffset
= 2
Attempt to read with a maximum offset (2) less than the start offset (0).
inside logsegment messageset sizeinBytes = 76 length = 76 startposition = 0
Reading 10000 bytes from offset 0 in log test1-0 of length 76 bytes, maxOffset
= 2
Attempt to read with a maximum offset (2) less than the start offset (0).
inside logsegment messageset sizeinBytes = 76 length = 76 startposition = 0
bytesReadable = 228
Highwatermark for topic test3 partition 0 updated to 2
junit.framework.AssertionFailedError:
Expected :List(a_test3, b_test3)
Actual :List()
> 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
