kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apache Jenkins Server <jenk...@builds.apache.org>
Subject Build failed in Jenkins: Kafka-0.8 #91
Date Thu, 25 Oct 2012 19:05:35 GMT
See <https://builds.apache.org/job/Kafka-0.8/91/changes>

Changes:

[junrao] produce/fetch remote time metric not set correctly when num.acks = 1; patched by
Jun Rao; reviewed by Neha Narkhede; KAFKA-584

------------------------------------------
[...truncated 3235 lines...]
	at scala.collection.immutable.Map$Map1.map(Map.scala:93)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[2012-10-25 19:05:27,429] ERROR [KafkaApi-0] Error processing ProducerRequest on test:0 (kafka.server.KafkaApis:102)
kafka.common.UnknownTopicOrPartitionException: Topic test partition 0 doesn't exist on 0
	at kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:142)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:191)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:186)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map1.map(Map.scala:93)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[info] Test Passed: testReachableServer(kafka.producer.SyncProducerTest)
[info] Test Starting: testEmptyProduceRequest(kafka.producer.SyncProducerTest)
[info] Test Passed: testEmptyProduceRequest(kafka.producer.SyncProducerTest)
[info] Test Starting: testMessageSizeTooLarge(kafka.producer.SyncProducerTest)
[2012-10-25 19:05:28,705] ERROR [KafkaApi-0] Error processing ProducerRequest on test:0 (kafka.server.KafkaApis:102)
kafka.common.MessageSizeTooLargeException: Message size is 1000023 bytes which exceeds the
maximum configured message size of 1000000.
	at kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:324)
	at kafka.log.Log$$anonfun$analyzeAndValidateMessageSet$1.apply(Log.scala:310)
	at scala.collection.Iterator$class.foreach(Iterator.scala:631)
	at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
	at kafka.log.Log.analyzeAndValidateMessageSet(Log.scala:310)
	at kafka.log.Log.append(Log.scala:238)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:193)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:186)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map1.foreach(Map.scala:105)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map1.map(Map.scala:93)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[info] Test Passed: testMessageSizeTooLarge(kafka.producer.SyncProducerTest)
[info] Test Starting: testProduceCorrectlyReceivesResponse(kafka.producer.SyncProducerTest)
[2012-10-25 19:05:28,936] ERROR [KafkaApi-0] Error processing ProducerRequest on topic1:0
(kafka.server.KafkaApis:102)
kafka.common.UnknownTopicOrPartitionException: Topic topic1 partition 0 doesn't exist on 0
	at kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:142)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:191)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:186)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.foreach(Map.scala:152)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.map(Map.scala:132)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[2012-10-25 19:05:28,937] ERROR [KafkaApi-0] Error processing ProducerRequest on topic3:0
(kafka.server.KafkaApis:102)
kafka.common.UnknownTopicOrPartitionException: Topic topic3 partition 0 doesn't exist on 0
	at kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:142)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:191)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:186)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.foreach(Map.scala:152)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.map(Map.scala:132)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[2012-10-25 19:05:28,937] ERROR [KafkaApi-0] Error processing ProducerRequest on topic2:0
(kafka.server.KafkaApis:102)
kafka.common.UnknownTopicOrPartitionException: Topic topic2 partition 0 doesn't exist on 0
	at kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:142)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:191)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:186)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.foreach(Map.scala:152)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.map(Map.scala:132)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[2012-10-25 19:05:30,603] ERROR [KafkaApi-0] Error processing ProducerRequest on topic2:0
(kafka.server.KafkaApis:102)
kafka.common.UnknownTopicOrPartitionException: Topic topic2 partition 0 doesn't exist on 0
	at kafka.server.ReplicaManager.getLeaderReplicaIfLocal(ReplicaManager.scala:142)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:191)
	at kafka.server.KafkaApis$$anonfun$appendToLocalLog$2.apply(KafkaApis.scala:186)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.foreach(Map.scala:152)
	at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
	at scala.collection.immutable.Map$Map3.map(Map.scala:132)
	at kafka.server.KafkaApis.appendToLocalLog(KafkaApis.scala:186)
	at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:126)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:56)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:40)
	at java.lang.Thread.run(Thread.java:662)
[info] Test Passed: testProduceCorrectlyReceivesResponse(kafka.producer.SyncProducerTest)
[info] Test Starting: testProducerCanTimeout(kafka.producer.SyncProducerTest)
[info] Test Passed: testProducerCanTimeout(kafka.producer.SyncProducerTest)
[info] == core-kafka / kafka.producer.SyncProducerTest ==
[info] 
[info] == core-kafka / kafka.integration.TopicMetadataTest ==
[info] Test Starting: testTopicMetadataRequest(kafka.integration.TopicMetadataTest)
[info] Test Passed: testTopicMetadataRequest(kafka.integration.TopicMetadataTest)
[info] Test Starting: testBasicTopicMetadata(kafka.integration.TopicMetadataTest)
[info] Test Passed: testBasicTopicMetadata(kafka.integration.TopicMetadataTest)
[info] Test Starting: testAutoCreateTopic(kafka.integration.TopicMetadataTest)
[info] Test Passed: testAutoCreateTopic(kafka.integration.TopicMetadataTest)
[info] == core-kafka / kafka.integration.TopicMetadataTest ==
[info] 
[info] == core-kafka / kafka.api.RequestResponseSerializationTest ==
[info] Test Starting: testSerializationAndDeserialization
[info] Test Passed: testSerializationAndDeserialization
[info] == core-kafka / kafka.api.RequestResponseSerializationTest ==
[info] 
[info] == core-kafka / kafka.zk.ZKEphemeralTest ==
[info] Test Starting: testEphemeralNodeCleanup(kafka.zk.ZKEphemeralTest)
[info] Test Passed: testEphemeralNodeCleanup(kafka.zk.ZKEphemeralTest)
[info] == core-kafka / kafka.zk.ZKEphemeralTest ==
[info] 
[info] == core-kafka / kafka.network.SocketServerTest ==
[info] Test Starting: simpleRequest
[info] Test Passed: simpleRequest
[info] Test Starting: tooBigRequestIsRejected
[info] Test Passed: tooBigRequestIsRejected
[info] == core-kafka / kafka.network.SocketServerTest ==
[info] 
[info] == core-kafka / kafka.log4j.KafkaLog4jAppenderTest ==
[info] Test Starting: testKafkaLog4jConfigs(kafka.log4j.KafkaLog4jAppenderTest)
[2012-10-25 19:05:31,915] WARN Exception causing close of session 0x0 due to java.io.IOException:
ZooKeeperServer not running (org.apache.zookeeper.server.NIOServerCnxn:639)
log4j:WARN No appenders could be found for logger (org.I0Itec.zkclient.ZkEventThread).
log4j:WARN Please initialize the log4j system properly.
[info] Test Passed: testKafkaLog4jConfigs(kafka.log4j.KafkaLog4jAppenderTest)
[info] Test Starting: testLog4jAppends(kafka.log4j.KafkaLog4jAppenderTest)
[error] Test Failed: testLog4jAppends(kafka.log4j.KafkaLog4jAppenderTest)
junit.framework.AssertionFailedError: expected:<5> but was:<6>
	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.log4j.KafkaLog4jAppenderTest.testLog4jAppends(KafkaLog4jAppenderTest.scala:156)
	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.log4j.KafkaLog4jAppenderTest ==
[info] 
[info] == core-kafka / kafka.integration.FetcherTest ==
[info] Test Starting: testFetcher(kafka.integration.FetcherTest)
[info] Test Passed: testFetcher(kafka.integration.FetcherTest)
[info] == core-kafka / kafka.integration.FetcherTest ==
[info] 
[info] == core-kafka / kafka.message.MessageCompressionTest ==
[info] Test Starting: testSimpleCompressDecompress
[info] Test Passed: testSimpleCompressDecompress
[info] Test Starting: testComplexCompressDecompress
[info] Test Passed: testComplexCompressDecompress
[info] == core-kafka / kafka.message.MessageCompressionTest ==
[info] 
[info] == core-kafka / test-finish ==
[error] Failed: : Total 159, Failed 4, Errors 0, Passed 155, Skipped 0
[info] == core-kafka / test-finish ==
[info] 
[info] == core-kafka / Test cleanup 1 ==
[info] Deleting directory /tmp/sbt_2e76f327
[info] == core-kafka / Test cleanup 1 ==
[info] 
[info] == core-kafka / test-cleanup ==
[info] == core-kafka / test-cleanup ==
[info] 
[info] == hadoop producer / test-compile ==
[info]   Source analysis: 0 new/modified, 0 indirectly invalidated, 0 removed.
[info] Compiling test sources...
[info] Nothing to compile.
[info]   Post-analysis: 0 classes.
[info] == hadoop producer / test-compile ==
[info] 
[info] == hadoop consumer / copy-test-resources ==
[info] == hadoop consumer / copy-test-resources ==
[info] 
[info] == java-examples / test-compile ==
[info]   Source analysis: 0 new/modified, 0 indirectly invalidated, 0 removed.
[info] Compiling test sources...
[info] Nothing to compile.
[info]   Post-analysis: 0 classes.
[info] == java-examples / test-compile ==
[info] 
[info] == hadoop consumer / copy-resources ==
[info] == hadoop consumer / copy-resources ==
[info] 
[info] == java-examples / copy-resources ==
[info] == java-examples / copy-resources ==
[info] 
[info] == perf / copy-resources ==
[info] == perf / copy-resources ==
[error] Error running kafka.server.LogRecoveryTest: Test FAILED
[error] Error running kafka.integration.PrimitiveApiTest: Test FAILED
[error] Error running kafka.consumer.ZookeeperConsumerConnectorTest: Test
FAILED
[error] Error running kafka.log4j.KafkaLog4jAppenderTest: Test FAILED
[error] Error running test: One or more subtasks failed
[info] 
[info] Total time: 239 s, completed Oct 25, 2012 7:05:34 PM
[info] 
[info] Total session time: 240 s, completed Oct 25, 2012 7:05:34 PM
[error] Error during build.
Build step 'Execute shell' marked build as failure

Mime
View raw message