[
https://issues.apache.org/jira/browse/KAFKA-380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13411921#comment-13411921
]
John Fung commented on KAFKA-380:
---------------------------------
Thanks Jun for reviewing. The test is hanging due to the following exception
thrown by ProducerPerformance:
[2012-07-10 15:38:31,510] INFO Beging shutting down ProducerSendThread
(kafka.producer.async.ProducerSendThread)
[2012-07-10 15:39:01,491] INFO Disconnecting from 127.0.0.1:9093
(kafka.producer.SyncProducer)
[2012-07-10 15:39:01,491] INFO Disconnecting from 127.0.0.1:9093
(kafka.producer.SyncProducer)
[2012-07-10 15:39:01,491] INFO Disconnecting from 127.0.0.1:9093
(kafka.producer.SyncProducer)
[2012-07-10 15:39:01,491] INFO Disconnecting from 127.0.0.1:9093
(kafka.producer.SyncProducer)
[2012-07-10 15:39:01,495] ERROR Error in handling batch of 1 events
(kafka.producer.async.ProducerSendThread)
java.net.SocketTimeoutException
at
sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:201)
at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:86)
at
java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:221)
at kafka.utils.Utils$.read(Utils.scala:603)
at
kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
at kafka.network.Receive$class.readCompletely(Transmission.scala:55)
at
kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
at kafka.network.BlockingChannel.receive(BlockingChannel.scala:92)
at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:78)
at kafka.producer.SyncProducer.doSend(SyncProducer.scala:76)
at kafka.producer.SyncProducer.send(SyncProducer.scala:115)
at
kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:76)
at
kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:45)
at
kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:129)
at
kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:95)
at
kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:94)
at
scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
at scala.collection.immutable.List.foreach(List.scala:45)
at
scala.collection.generic.TraversableForwarder$class.foreach(TraversableForwarder.scala:44)
at scala.collection.mutable.ListBuffer.foreach(ListBuffer.scala:42)
at
kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:94)
at
kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:65)
at
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:49)
at
kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:96)
at
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:82)
at
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:60)
at scala.collection.immutable.Stream.foreach(Stream.scala:254)
at
kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:59)
at
kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:37)
> Enhance single_host_multi_brokers test with failure to trigger leader
> re-election in replication
> ------------------------------------------------------------------------------------------------
>
> Key: KAFKA-380
> URL: https://issues.apache.org/jira/browse/KAFKA-380
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-380-v1.patch, kafka-380-v2.patch,
> kafka-380-v3.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
