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 #9
Date Tue, 24 Jul 2012 19:03:49 GMT
See <https://builds.apache.org/job/Kafka-0.8/9/changes>

Changes:

[nehanarkhede] KAFKA-350 Enable message replication in the presence of failures; patched by
Neha Narkhede; reviewed by Jun Rao and Jay Kreps

------------------------------------------
[...truncated 548 lines...]
	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] Test Starting: testConsumerDecoder(kafka.consumer.ZookeeperConsumerConnectorTest)
[2012-07-24 19:03:21,728] WARN fsync-ing the write ahead log in SyncThread:0 took 2858ms which
will adversely effect operation latency. See the ZooKeeper troubleshooting guide (org.apache.zookeeper.server.persistence.FileTxnLog:321)
[2012-07-24 19:03:28,398] ERROR Failed to collate messages by topic, partition due to (kafka.producer.async.DefaultEventHandler:99)
kafka.common.KafkaException: Failed to fetch topic metadata for topic: topic1
	at kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
	at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:141)
	at kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:102)
	at kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:101)
	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
	at kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:101)
	at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:66)
	at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:49)
	at kafka.producer.Producer.send(Producer.scala:70)
	at kafka.consumer.ZookeeperConsumerConnectorTest.sendMessagesToBrokerPartition(ZookeeperConsumerConnectorTest.scala:392)
	at kafka.consumer.ZookeeperConsumerConnectorTest.testConsumerDecoder(ZookeeperConsumerConnectorTest.scala:316)
	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)
[2012-07-24 19:03:29,550] ERROR Error while electing leader for topic topic1 partition 0 (kafka.utils.ZkUtils$:99)
org.I0Itec.zkclient.exception.ZkInterruptedException: java.lang.InterruptedException
	at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:687)
	at org.I0Itec.zkclient.ZkClient.create(ZkClient.java:304)
	at org.I0Itec.zkclient.ZkClient.createEphemeral(ZkClient.java:328)
	at kafka.utils.ZkUtils$.createEphemeralPath(ZkUtils.scala:240)
	at kafka.utils.ZkUtils$.createEphemeralPathExpectConflict(ZkUtils.scala:251)
	at kafka.utils.ZkUtils$.tryToBecomeLeaderForPartition(ZkUtils.scala:159)
	at kafka.server.KafkaZooKeeper.leaderElection(KafkaZooKeeper.scala:215)
	at kafka.server.KafkaZooKeeper.kafka$server$KafkaZooKeeper$$startReplica(KafkaZooKeeper.scala:188)
	at kafka.server.KafkaZooKeeper$$anonfun$kafka$server$KafkaZooKeeper$$startReplicasForPartitions$1.apply$mcVI$sp(KafkaZooKeeper.scala:171)
	at kafka.server.KafkaZooKeeper$$anonfun$kafka$server$KafkaZooKeeper$$startReplicasForPartitions$1.apply(KafkaZooKeeper.scala:166)
	at kafka.server.KafkaZooKeeper$$anonfun$kafka$server$KafkaZooKeeper$$startReplicasForPartitions$1.apply(KafkaZooKeeper.scala:166)
	at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
	at scala.collection.immutable.List.foreach(List.scala:45)
	at kafka.server.KafkaZooKeeper.kafka$server$KafkaZooKeeper$$startReplicasForPartitions(KafkaZooKeeper.scala:166)
	at kafka.server.KafkaZooKeeper$$anonfun$handleNewTopics$2.apply(KafkaZooKeeper.scala:137)
	at kafka.server.KafkaZooKeeper$$anonfun$handleNewTopics$2.apply(KafkaZooKeeper.scala:133)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80)
	at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:80)
	at scala.collection.Iterator$class.foreach(Iterator.scala:631)
	at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:161)
	at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:194)
	at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:39)
	at scala.collection.mutable.HashMap.foreach(HashMap.scala:80)
	at kafka.server.KafkaZooKeeper.handleNewTopics(KafkaZooKeeper.scala:133)
	at kafka.server.KafkaZooKeeper$TopicChangeListener.handleChildChange(KafkaZooKeeper.scala:302)
	at org.I0Itec.zkclient.ZkClient$7.run(ZkClient.java:568)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
Caused by: java.lang.InterruptedException
	at java.lang.Object.wait(Native Method)
	at java.lang.Object.wait(Object.java:485)
	at org.apache.zookeeper.ClientCnxn.submitRequest(ClientCnxn.java:1344)
	at org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:641)
	at org.I0Itec.zkclient.ZkConnection.create(ZkConnection.java:87)
	at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:308)
	at org.I0Itec.zkclient.ZkClient$1.call(ZkClient.java:304)
	at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
	... 26 more
[error] Test Failed: testConsumerDecoder(kafka.consumer.ZookeeperConsumerConnectorTest)
kafka.common.KafkaException: Failed to fetch topic metadata for topic: topic1
	at kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
	at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:141)
	at kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:102)
	at kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:101)
	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
	at kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:101)
	at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:66)
	at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:49)
	at kafka.producer.Producer.send(Producer.scala:70)
	at kafka.consumer.ZookeeperConsumerConnectorTest.sendMessagesToBrokerPartition(ZookeeperConsumerConnectorTest.scala:392)
	at kafka.consumer.ZookeeperConsumerConnectorTest.testConsumerDecoder(ZookeeperConsumerConnectorTest.scala:316)
	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] Test Starting: testLeaderSelectionForPartition(kafka.consumer.ZookeeperConsumerConnectorTest)
[2012-07-24 19:03:33,081] ERROR Failed to send the following reqeusts: ListBuffer(ProducerData(topic1,0,ArrayBuffer(message(magic
= 1, attributes = 0, crc = 145707750, payload = java.nio.HeapByteBuffer[pos=0 lim=11 cap=11]),
message(magic = 1, attributes = 0, crc = 2141741680, payload = java.nio.HeapByteBuffer[pos=0
lim=11 cap=11])))) (kafka.producer.async.DefaultEventHandler:93)
[error] Test Failed: testLeaderSelectionForPartition(kafka.consumer.ZookeeperConsumerConnectorTest)
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
	at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:60)
	at kafka.producer.Producer.send(Producer.scala:70)
	at kafka.consumer.ZookeeperConsumerConnectorTest$$anonfun$sendMessages$1.apply$mcVI$sp(ZookeeperConsumerConnectorTest.scala:410)
	at scala.collection.immutable.Range$ByOne$class.foreach$mVc$sp(Range.scala:285)
	at scala.collection.immutable.Range$$anon$2.foreach$mVc$sp(Range.scala:265)
	at kafka.consumer.ZookeeperConsumerConnectorTest.sendMessages(ZookeeperConsumerConnectorTest.scala:405)
	at kafka.consumer.ZookeeperConsumerConnectorTest.testLeaderSelectionForPartition(ZookeeperConsumerConnectorTest.scala:358)
	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.consumer.ZookeeperConsumerConnectorTest ==
[info] 
[info] == core-kafka / kafka.consumer.TopicFilterTest ==
[info] Test Starting: testWhitelists
[info] Test Passed: testWhitelists
[info] Test Starting: testBlacklists
[info] Test Passed: testBlacklists
[info] == core-kafka / kafka.consumer.TopicFilterTest ==
[info] 
[info] == core-kafka / kafka.server.ReplicaFetchTest ==
[info] Test Starting: testReplicaFetcherThread(kafka.server.ReplicaFetchTest)
[2012-07-24 19:03:39,438] ERROR Timing out after 1000 ms since leader is not elected for topic
foo partition 0 (kafka.utils.TestUtils$:93)
[2012-07-24 19:03:41,015] ERROR Leader exists for topic foo partition 0 (kafka.utils.ZkUtils$:93)
[2012-07-24 19:03:41,507] ERROR Cannot truncate log to 0 since the log start offset is 0 and
end offset is 0 (kafka.log.Log:93)
[2012-07-24 19:03:41,589] ERROR Uncaught exception in thread 'kafka-request-handler-1': (kafka.utils.Utils$:99)
kafka.common.LeaderNotAvailableException: Leader for topic foo partition 0 does not exist
	at kafka.cluster.Partition.leaderReplica(Partition.scala:82)
	at kafka.cluster.Partition.leaderHW(Partition.scala:93)
	at kafka.server.ReplicaManager.checkIfISRCanBeExpanded(ReplicaManager.scala:217)
	at kafka.server.ReplicaManager.recordFollowerPosition(ReplicaManager.scala:230)
	at kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$1$$anonfun$apply$14.apply(KafkaApis.scala:278)
	at kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$1$$anonfun$apply$14.apply(KafkaApis.scala:277)
	at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
	at kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$1.apply(KafkaApis.scala:277)
	at kafka.server.KafkaApis$$anonfun$maybeUpdatePartitionHW$1.apply(KafkaApis.scala:274)
	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
	at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
	at kafka.server.KafkaApis.maybeUpdatePartitionHW(KafkaApis.scala:274)
	at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:216)
	at kafka.server.KafkaApis.handle(KafkaApis.scala:54)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:35)
	at java.lang.Thread.run(Thread.java:662)
[2012-07-24 19:03:42,630] ERROR Leader exists for topic bar partition 0 (kafka.utils.ZkUtils$:93)
[2012-07-24 19:03:42,632] ERROR Cannot truncate log to 0 since the log start offset is 0 and
end offset is 0 (kafka.log.Log:93)
[2012-07-24 19:03:48,218] ERROR Failed to send the following reqeusts: ListBuffer(ProducerData(foo,null,List(message(magic
= 1, attributes = 0, crc = 2326977762, payload = java.nio.HeapByteBuffer[pos=0 lim=5 cap=5]),
message(magic = 1, attributes = 0, crc = 331058520, payload = java.nio.HeapByteBuffer[pos=0
lim=5 cap=5]), message(magic = 1, attributes = 0, crc = 1690090958, payload = java.nio.HeapByteBuffer[pos=0
lim=5 cap=5]), message(magic = 1, attributes = 0, crc = 4208470125, payload = java.nio.HeapByteBuffer[pos=0
lim=5 cap=5]))), ProducerData(bar,null,List(message(magic = 1, attributes = 0, crc = 2380208379,
payload = java.nio.HeapByteBuffer[pos=0 lim=5 cap=5]), message(magic = 1, attributes = 0,
crc = 349587777, payload = java.nio.HeapByteBuffer[pos=0 lim=5 cap=5]), message(magic = 1,
attributes = 0, crc = 1674672599, payload = java.nio.HeapByteBuffer[pos=0 lim=5 cap=5]), message(magic
= 1, attributes = 0, crc = 4084098118, payload = java.nio.HeapByteBuffer[pos=0 lim=5 cap=5]))))
(kafka.producer.async.DefaultEventHandler:93)
[2012-07-24 19:03:48,663] FATAL Halting due to unrecoverable I/O error while handling producer
request (kafka.log.Log:112)
java.nio.channels.ClosedByInterruptException
	at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:184)
	at sun.nio.ch.FileChannelImpl.write(FileChannelImpl.java:203)
	at kafka.message.ByteBufferMessageSet.writeTo(ByteBufferMessageSet.scala:76)
	at kafka.message.FileMessageSet.append(FileMessageSet.scala:153)
	at kafka.log.Log.liftedTree1$1(Log.scala:260)
	at kafka.log.Log.append(Log.scala:258)
	at kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:40)
	at kafka.server.AbstractFetcherThread$$anonfun$run$5$$anonfun$apply$1.apply(AbstractFetcherThread.scala:97)
	at kafka.server.AbstractFetcherThread$$anonfun$run$5$$anonfun$apply$1.apply(AbstractFetcherThread.scala:89)
	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
	at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
	at kafka.server.AbstractFetcherThread$$anonfun$run$5.apply(AbstractFetcherThread.scala:89)
	at kafka.server.AbstractFetcherThread$$anonfun$run$5.apply(AbstractFetcherThread.scala:88)
	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
	at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
	at kafka.server.AbstractFetcherThread.run(AbstractFetcherThread.scala:88)
Build step 'Execute shell' marked build as failure

Mime
View raw message