For what it's worth, I only get ZK test failures about 95% of the time, and just overall weirdness with ZK the remaining 5%. Of the 95%, it's with ZK balancing. BTW, this is on OSX 10.6.
[info] == core-kafka / kafka.zk.ZKLoadBalanceTest == [info] Test Starting: testLoadBalance(kafka.zk.ZKLoadBalanceTest) log4j:WARN No appenders could be found for logger (org.apache.zookeeper.server.ZooKeeperServer). log4j:WARN Please initialize the log4j system properly. [error] Test Failed: testLoadBalance(kafka.zk.ZKLoadBalanceTest) junit.framework.AssertionFailedError: expected:<5> but was:<2> at junit.framework.Assert.fail(Assert.java:47) at junit.framework.Assert.failNotEquals(Assert.java:277) at junit.framework.Assert.assertEquals(Assert.java:64) at junit.framework.Assert.assertEquals(Assert.java:195) at junit.framework.Assert.assertEquals(Assert.java:201) at kafka.zk.ZKLoadBalanceTest.checkSetEqual(ZKLoadBalanceTest.scala:121) at kafka.zk.ZKLoadBalanceTest.testLoadBalance(ZKLoadBalanceTest.scala:89) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:597) at junit.framework.TestCase.runTest(TestCase.java:164) at junit.framework.TestCase.runBare(TestCase.java:130) at junit.framework.TestResult$1.protect(TestResult.java:110) at junit.framework.TestResult.runProtected(TestResult.java:128) at junit.framework.TestResult.run(TestResult.java:113) at junit.framework.TestCase.run(TestCase.java:120) at junit.framework.TestSuite.runTest(TestSuite.java:228) at junit.framework.TestSuite.run(TestSuite.java:223) at junit.framework.TestSuite.runTest(TestSuite.java:228) at junit.framework.TestSuite.run(TestSuite.java:223) at org.scalatest.junit.JUnit3Suite.run(JUnit3Suite.scala:309) at org.scalatest.tools.ScalaTestFramework$ScalaTestRunner.run(ScalaTestFramework.scala:40) at sbt.TestRunner.run(TestFramework.scala:53) at sbt.TestRunner.runTest$1(TestFramework.scala:67) at sbt.TestRunner.run(TestFramework.scala:76) at sbt.TestFramework$$anonfun$10$$anonfun$apply$11.runTest$2(TestFramework.scala:194) at sbt.TestFramework$$anonfun$10$$anonfun$apply$11$$anonfun$apply$12.apply(TestFramework.scala:205) at sbt.TestFramework$$anonfun$10$$anonfun$apply$11$$anonfun$apply$12.apply(TestFramework.scala:205) at sbt.NamedTestTask.run(TestFramework.scala:92) at sbt.ScalaProject$$anonfun$sbt$ScalaProject$$toTask$1.apply(ScalaProject.scala:193) at sbt.ScalaProject$$anonfun$sbt$ScalaProject$$toTask$1.apply(ScalaProject.scala:193) at sbt.TaskManager$Task.invoke(TaskManager.scala:62) at sbt.impl.RunTask.doRun$1(RunTask.scala:77) at sbt.impl.RunTask.runTask(RunTask.scala:85) at sbt.impl.RunTask.sbt$impl$RunTask$$runIfNotRoot(RunTask.scala:60) at sbt.impl.RunTask$$anonfun$runTasksExceptRoot$2.apply(RunTask.scala:48) at sbt.impl.RunTask$$anonfun$runTasksExceptRoot$2.apply(RunTask.scala:48) at sbt.Distributor$Run$Worker$$anonfun$2.apply(ParallelRunner.scala:131) at sbt.Distributor$Run$Worker$$anonfun$2.apply(ParallelRunner.scala:131) at sbt.Control$.trapUnit(Control.scala:19) at sbt.Distributor$Run$Worker.run(ParallelRunner.scala:131) [info] == core-kafka / kafka.zk.ZKLoadBalanceTest == On Wed, Nov 30, 2011 at 12:12 AM, Joe Stein <crypt...@gmail.com> wrote: > that was from running > > ./sbt test > > btw > > On Tue, Nov 29, 2011 at 11:52 PM, Joe Stein <crypt...@gmail.com> wrote: > > > [success] Build completed successfully. > > [root@ip-10-116-225-87 kafka]# uname -r > > 2.6.21.7-2.fc8xen > > > > works alright, np > > > > On Tue, Nov 29, 2011 at 10:40 PM, Joe Stein <crypt...@gmail.com> wrote: > > > >> I have had issues on similar OS I want to blame sbt version but have had > >> issue applying the patch for 0.10 ( I forget the JIRA) glad it is not > just > >> me I will circle my wagons and follow up. > >> > >> /* > >> Joe Stein > >> http://www.medialets.com > >> Twitter: @allthingshadoop > >> */ > >> > >> On Nov 29, 2011, at 10:29 PM, Neha Narkhede <neha.narkh...@gmail.com> > >> wrote: > >> > >> >>> My team is beginning to work on some core features within Kafka as > you > >> > know and this gets in our way for implementation. > >> > > >> > Good to hear. We agree that this is high priority, and would > appreciate > >> a > >> > patch if you've been able to reproduce certain errors. > >> > > >> > Thanks, > >> > Neha > >> > > >> > On Tue, Nov 29, 2011 at 7:15 PM, Taylor Gautier <tgaut...@tagged.com> > >> wrote: > >> > > >> >> Just one? :-) > >> >> > >> >> Ok - not fair I know - but I have all kinds of weird behavior with > the > >> >> zookeeper tests. > >> >> > >> >> This makes it hard to develop because it's really difficult to > >> >> distinguish the signal from the noise. > >> >> > >> >> It's really important that tests pass reliably. What's the status of > >> >> your issue and the zookeeper ones? > >> >> > >> >> My team is beginning to work on some core features within Kafka as > you > >> >> know and this gets in our way for implementation. > >> >> > >> >> I think it should be a high priority to eliminate these issues. > >> >> > >> >> On Nov 29, 2011, at 3:23 PM, Neha Narkhede <neha.narkh...@gmail.com> > >> >> wrote: > >> >> > >> >>> Hi, > >> >>> > >> >>> I moved to linux and one unit test consistently fails - > >> >>> > >> >>> [error] Test Failed: testCleanupExpiredSegments > >> >>> junit.framework.AssertionFailedError: Now there should only be only > >> one > >> >>> segment. expected:<1> but was:<12> > >> >>> at junit.framework.Assert.fail(Assert.java:47) > >> >>> at junit.framework.Assert.failNotEquals(Assert.java:277) > >> >>> at junit.framework.Assert.assertEquals(Assert.java:64) > >> >>> at junit.framework.Assert.assertEquals(Assert.java:195) > >> >>> at > >> >>> > >> >> > >> > kafka.log.LogManagerTest.testCleanupExpiredSegments(LogManagerTest.scala:87) > >> >>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > >> >>> at > >> >>> > >> >> > >> > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) > >> >>> at > >> >>> > >> >> > >> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) > >> >>> at java.lang.reflect.Method.invoke(Method.java:597) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.TestMethodRunner.executeMethodBody(TestMethodRunner.java:99) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.TestMethodRunner.runUnprotected(TestMethodRunner.java:81) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.BeforeAndAfterRunner.runProtected(BeforeAndAfterRunner.java:34) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.TestMethodRunner.runMethod(TestMethodRunner.java:75) > >> >>> at > >> >>> > >> > org.junit.internal.runners.TestMethodRunner.run(TestMethodRunner.java:45) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.TestClassMethodsRunner.invokeTestMethod(TestClassMethodsRunner.java:71) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.TestClassMethodsRunner.run(TestClassMethodsRunner.java:35) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.TestClassRunner$1.runUnprotected(TestClassRunner.java:42) > >> >>> at > >> >>> > >> >> > >> > org.junit.internal.runners.BeforeAndAfterRunner.runProtected(BeforeAndAfterRunner.java:34) > >> >>> at > >> >>> > >> org.junit.internal.runners.TestClassRunner.run(TestClassRunner.java:52) > >> >>> at > >> >>> > >> org.junit.internal.runners.CompositeRunner.run(CompositeRunner.java:29) > >> >>> at org.junit.runner.JUnitCore.run(JUnitCore.java:121) > >> >>> at org.junit.runner.JUnitCore.run(JUnitCore.java:100) > >> >>> at org.junit.runner.JUnitCore.run(JUnitCore.java:91) > >> >>> at org.scalatest.junit.JUnitSuite$class.run(JUnitSuite.scala:261) > >> >>> at kafka.log.LogManagerTest.run(LogManagerTest.scala:28) > >> >>> at > >> >>> > >> >> > >> > org.scalatest.tools.ScalaTestFramework$ScalaTestRunner.run(ScalaTestFramework.scala:40) > >> >>> at sbt.TestRunner.run(TestFramework.scala:53) > >> >>> at sbt.TestRunner.runTest$1(TestFramework.scala:67) > >> >>> at sbt.TestRunner.run(TestFramework.scala:76) > >> >>> at > >> >>> > >> >> > >> > sbt.TestFramework$$anonfun$10$$anonfun$apply$11.runTest$2(TestFramework.scala:194) > >> >>> at > >> >>> > >> >> > >> > sbt.TestFramework$$anonfun$10$$anonfun$apply$11$$anonfun$apply$12.apply(TestFramework.scala:205) > >> >>> at > >> >>> > >> >> > >> > sbt.TestFramework$$anonfun$10$$anonfun$apply$11$$anonfun$apply$12.apply(TestFramework.scala:205) > >> >>> at sbt.NamedTestTask.run(TestFramework.scala:92) > >> >>> at > >> >>> > >> >> > >> > sbt.ScalaProject$$anonfun$sbt$ScalaProject$$toTask$1.apply(ScalaProject.scala:193) > >> >>> at > >> >>> > >> >> > >> > sbt.ScalaProject$$anonfun$sbt$ScalaProject$$toTask$1.apply(ScalaProject.scala:193) > >> >>> at sbt.TaskManager$Task.invoke(TaskManager.scala:62) > >> >>> at sbt.impl.RunTask.doRun$1(RunTask.scala:77) > >> >>> at sbt.impl.RunTask.runTask(RunTask.scala:85) > >> >>> at > sbt.impl.RunTask.sbt$impl$RunTask$$runIfNotRoot(RunTask.scala:60) > >> >>> at > >> >>> > sbt.impl.RunTask$$anonfun$runTasksExceptRoot$2.apply(RunTask.scala:48) > >> >>> at > >> >>> > sbt.impl.RunTask$$anonfun$runTasksExceptRoot$2.apply(RunTask.scala:48) > >> >>> at > >> >> sbt.Distributor$Run$Worker$$anonfun$2.apply(ParallelRunner.scala:131) > >> >>> at > >> >> sbt.Distributor$Run$Worker$$anonfun$2.apply(ParallelRunner.scala:131) > >> >>> at sbt.Control$.trapUnit(Control.scala:19) > >> >>> at sbt.Distributor$Run$Worker.run(ParallelRunner.scala:131) > >> >>> > >> >>> Wanted to check if others run into this as well ? > >> >>> > >> >>> Thanks, > >> >>> Neha > >> >> > >> > > > > > > > > -- > > > > /* > > Joe Stein > > http://www.linkedin.com/in/charmalloc > > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > > */ > > > > > > -- > > /* > Joe Stein > http://www.linkedin.com/in/charmalloc > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > */ >