PrimitiveApiTest failed while checking consumer iterators. Haven't seen this error in a while.
On Tue, Oct 9, 2012 at 7:10 PM, Apache Jenkins Server <jenk...@builds.apache.org> wrote: > See <https://builds.apache.org/job/Kafka-trunk/149/changes> > > Changes: > > [jjkoshy] Fix wildcard consumption to work with greater than one stream; > KAFKA-550; patched by Joel Koshy; reviewed by Jun Rao and Neha Narkhede. > > ------------------------------------------ > [...truncated 2918 lines...] > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.message.ByteBufferMessageSetTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.javaapi.integration.PrimitiveApiTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndMultiFetch(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndMultiFetch(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndMultiFetchWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndMultiFetchWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [0minfo [0m] [0mTest Starting: > testMultiProduce(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testMultiProduce(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testMultiProduceWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [31merror [0m] [0mTest Failed: > testMultiProduceWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > junit.framework.AssertionFailedError: Iterators have uneven length--first has > more > at junit.framework.Assert.fail(Assert.java:47) > at junit.framework.Assert.assertTrue(Assert.java:20) > at junit.framework.Assert.assertFalse(Assert.java:34) > at kafka.utils.TestUtils$.checkEquals(TestUtils.scala:230) > at > kafka.javaapi.integration.PrimitiveApiTest$$anonfun$testMultiProduceWithCompression$3.apply(PrimitiveApiTest.scala:399) > at > kafka.javaapi.integration.PrimitiveApiTest$$anonfun$testMultiProduceWithCompression$3.apply(PrimitiveApiTest.scala:396) > at > scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61) > at scala.collection.immutable.List.foreach(List.scala:45) > at > kafka.javaapi.integration.PrimitiveApiTest.testMultiProduceWithCompression(PrimitiveApiTest.scala:396) > 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) > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndFetch(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndFetch(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndFetchWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndFetchWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndMultiFetchJava(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndMultiFetchJava(kafka.javaapi.integration.PrimitiveApiTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndMultiFetchJavaWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndMultiFetchJavaWithCompression(kafka.javaapi.integration.PrimitiveApiTest) > [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.javaapi.integration.PrimitiveApiTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.javaapi.consumer.ZookeeperConsumerConnectorTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: > testBasic(kafka.javaapi.consumer.ZookeeperConsumerConnectorTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testBasic(kafka.javaapi.consumer.ZookeeperConsumerConnectorTest) [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.javaapi.consumer.ZookeeperConsumerConnectorTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.consumer.FetcherTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: testFetcher(kafka.consumer.FetcherTest) > [0m > [0m[ [0minfo [0m] [0mTest Passed: testFetcher(kafka.consumer.FetcherTest) > [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.consumer.FetcherTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.producer.AsyncProducerTest == > [0m > [0m[ [0minfo [0m] [0mTest Starting: testProducerQueueSize [0m > Queue is full.. > [0m[ [0minfo [0m] [0mTest Passed: testProducerQueueSize [0m > [0m[ [0minfo [0m] [0mTest Starting: testAddAfterQueueClosed [0m > [0m[ [0minfo [0m] [0mTest Passed: testAddAfterQueueClosed [0m > [0m[ [0minfo [0m] [0mTest Starting: testBatchSize [0m > [0m[ [0minfo [0m] [0mTest Passed: testBatchSize [0m > [0m[ [0minfo [0m] [0mTest Starting: testQueueTimeExpired [0m > [0m[ [0minfo [0m] [0mTest Passed: testQueueTimeExpired [0m > [0m[ [0minfo [0m] [0mTest Starting: testSenderThreadShutdown [0m > [0m[ [0minfo [0m] [0mTest Passed: testSenderThreadShutdown [0m > [0m[ [0minfo [0m] [0mTest Starting: testCollateEvents [0m > [0m[ [0minfo [0m] [0mTest Passed: testCollateEvents [0m > [0m[ [0minfo [0m] [0mTest Starting: testCollateAndSerializeEvents [0m > [0m[ [0minfo [0m] [0mTest Passed: testCollateAndSerializeEvents [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.producer.AsyncProducerTest == > [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / > unit.kafka.producer.ProducerMethodsTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: producerThrowsNoBrokersException [0m > [0m[ [0minfo [0m] [0mTest Passed: producerThrowsNoBrokersException [0m > [0m[ [0minfo [0m] [34m== core-kafka / > unit.kafka.producer.ProducerMethodsTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.message.MessageTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: testFieldValues [0m > [0m[ [0minfo [0m] [0mTest Passed: testFieldValues [0m > [0m[ [0minfo [0m] [0mTest Starting: testChecksum [0m > [0m[ [0minfo [0m] [0mTest Passed: testChecksum [0m > [0m[ [0minfo [0m] [0mTest Starting: testEquality [0m > [0m[ [0minfo [0m] [0mTest Passed: testEquality [0m > [0m[ [0minfo [0m] [0mTest Starting: testIsHashable [0m > [0m[ [0minfo [0m] [0mTest Passed: testIsHashable [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.message.MessageTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.producer.SyncProducerTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: testReachableServer [0m > [0m[ [0minfo [0m] [0mTest Passed: testReachableServer [0m > [0m[ [0minfo [0m] [0mTest Starting: testSingleMessageSizeTooLarge [0m > [0m[ [0minfo [0m] [0mTest Passed: testSingleMessageSizeTooLarge [0m > [0m[ [0minfo [0m] [0mTest Starting: testCompressedMessageSizeTooLarge [0m > [0m[ [0minfo [0m] [0mTest Passed: testCompressedMessageSizeTooLarge [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.producer.SyncProducerTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.zk.ZKEphemeralTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: > testEphemeralNodeCleanup(kafka.zk.ZKEphemeralTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testEphemeralNodeCleanup(kafka.zk.ZKEphemeralTest) [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.zk.ZKEphemeralTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.integration.BackwardsCompatibilityTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProtocolVersion0(kafka.integration.BackwardsCompatibilityTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProtocolVersion0(kafka.integration.BackwardsCompatibilityTest) [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.integration.BackwardsCompatibilityTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.server.ServerShutdownTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: testCleanShutdown [0m > [0m[ [0minfo [0m] [0mTest Passed: testCleanShutdown [0m > [0m[ [0minfo [0m] [34m== core-kafka / kafka.server.ServerShutdownTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.consumer.ZookeeperConsumerConnectorTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: > testBasic(kafka.consumer.ZookeeperConsumerConnectorTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testBasic(kafka.consumer.ZookeeperConsumerConnectorTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testCompression(kafka.consumer.ZookeeperConsumerConnectorTest) [0m > Sending messages for 1st consumer > Sending more messages for 2nd consumer > [0m[ [31merror [0m] [0mTest Failed: > testCompression(kafka.consumer.ZookeeperConsumerConnectorTest) [0m > org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to > zookeeper server within timeout: 400 > at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:876) > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98) > at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84) > at > kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:152) > at > kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:122) > at > kafka.consumer.ZookeeperConsumerConnectorTest.testCompression(ZookeeperConsumerConnectorTest.scala:149) > 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) > [0m[ [0minfo [0m] [0mTest Starting: > testCompressionSetConsumption(kafka.consumer.ZookeeperConsumerConnectorTest) > [0m > [0m[ [0minfo [0m] [0mTest Passed: > testCompressionSetConsumption(kafka.consumer.ZookeeperConsumerConnectorTest) > [0m > [0m[ [0minfo [0m] [0mTest Starting: > testConsumerDecoder(kafka.consumer.ZookeeperConsumerConnectorTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testConsumerDecoder(kafka.consumer.ZookeeperConsumerConnectorTest) [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.consumer.ZookeeperConsumerConnectorTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.integration.LazyInitProducerTest == [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndMultiFetch(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndMultiFetch(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testMultiProduce(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testMultiProduce(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testProduceAndFetch(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testProduceAndFetch(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Starting: > testMultiProduceResend(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [0mTest Passed: > testMultiProduceResend(kafka.integration.LazyInitProducerTest) [0m > [0m[ [0minfo [0m] [34m== core-kafka / > kafka.integration.LazyInitProducerTest == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== hadoop producer / test-compile == [0m > [0m[ [0minfo [0m] [0m Source analysis: 0 new/modified, 0 indirectly > invalidated, 0 removed. [0m > [0m[ [0minfo [0m] [0mCompiling test sources... [0m > [0m[ [0minfo [0m] [0mNothing to compile. [0m > [0m[ [0minfo [0m] [0m Post-analysis: 0 classes. [0m > [0m[ [0minfo [0m] [34m== hadoop producer / test-compile == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== perf / test-compile == [0m > [0m[ [0minfo [0m] [0m Source analysis: 0 new/modified, 0 indirectly > invalidated, 0 removed. [0m > [0m[ [0minfo [0m] [0mCompiling test sources... [0m > [0m[ [0minfo [0m] [0mNothing to compile. [0m > [0m[ [0minfo [0m] [0m Post-analysis: 0 classes. [0m > [0m[ [0minfo [0m] [34m== perf / test-compile == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== hadoop consumer / test-compile == [0m > [0m[ [0minfo [0m] [0m Source analysis: 0 new/modified, 0 indirectly > invalidated, 0 removed. [0m > [0m[ [0minfo [0m] [0mCompiling test sources... [0m > [0m[ [0minfo [0m] [0mNothing to compile. [0m > [0m[ [0minfo [0m] [0m Post-analysis: 0 classes. [0m > [0m[ [0minfo [0m] [34m== hadoop consumer / test-compile == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== hadoop producer / copy-resources == [0m > [0m[ [0minfo [0m] [34m== hadoop producer / copy-resources == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== hadoop consumer / copy-test-resources == [0m > [0m[ [0minfo [0m] [34m== hadoop consumer / copy-test-resources == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== java-examples / copy-test-resources == [0m > [0m[ [0minfo [0m] [34m== java-examples / copy-test-resources == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / Test cleanup 1 == [0m > [0m[ [0minfo [0m] [0mDeleting directory /tmp/sbt_e1a66bd1 [0m > [0m[ [0minfo [0m] [34m== core-kafka / Test cleanup 1 == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / test-finish == [0m > [0m[ [31merror [0m] [0mFailed: : Total 141, Failed 2, Errors 0, Passed 139, > Skipped 0 [0m > [0m[ [0minfo [0m] [34m== core-kafka / test-finish == [0m > [0m[ [0minfo [0m] [34m [0m > [0m[ [0minfo [0m] [34m== core-kafka / test-cleanup == [0m > [0m[ [0minfo [0m] [34m== core-kafka / test-cleanup == [0m > [0m[ [31merror [0m] [0mError running > kafka.javaapi.integration.PrimitiveApiTest: Test FAILED [0m > [0m[ [31merror [0m] [0mError running > kafka.consumer.ZookeeperConsumerConnectorTest: Test FAILED [0m > [0m[ [31merror [0m] [0mError running test: One or more subtasks failed [0m > [0m[ [0minfo [0m] [0m [0m > [0m[ [0minfo [0m] [0mTotal time: 147 s, completed Oct 10, 2012 2:10:29 AM > [0m > [0m[ [0minfo [0m] [0m [0m > [0m[ [0minfo [0m] [0mTotal session time: 147 s, completed Oct 10, 2012 > 2:10:29 AM [0m > [0m[ [31merror [0m] [0mError during build. [0m > Build step 'Execute shell' marked build as failure
