[
https://issues.apache.org/jira/browse/KAFKA-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Neha Narkhede updated KAFKA-1178:
---------------------------------
Attachment: KAFKA-1178_2013-12-11_10:30:19.patch
> Replica fetcher thread dies while becoming follower
> ---------------------------------------------------
>
> Key: KAFKA-1178
> URL: https://issues.apache.org/jira/browse/KAFKA-1178
> Project: Kafka
> Issue Type: Bug
> Components: replication
> Affects Versions: 0.8.1
> Reporter: Neha Narkhede
> Assignee: Neha Narkhede
> Priority: Critical
> Attachments: KAFKA-1178.patch, KAFKA-1178_2013-12-11_10:30:19.patch
>
>
> Replica fetcher thread dies due to
> 2013/12/10 17:48:24.845 [ReplicaFetcherThread] [ReplicaFetcherThread--3-500],
> Error due to
> kafka.common.KafkaException: error processing data for partition
> [pts-test_foo,1] offset 340
> at
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:139)
> at
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:111)
> at
> scala.collection.immutable.HashMap$HashMap1.foreach(HashMap.scala:125)
> at
> scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:344)
> at
> scala.collection.immutable.HashMap$HashTrieMap.foreach(HashMap.scala:344)
> at
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply$mcV$sp(AbstractFetcherThread.scala:111)
> at
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:111)
> at
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1.apply(AbstractFetcherThread.scala:111)
> at kafka.utils.Utils$.inLock(Utils.scala:538)
> at
> kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:110)
> at
> kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:88)
> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
> Caused by: java.util.NoSuchElementException: None.get
> at scala.None$.get(Option.scala:185)
> at scala.None$.get(Option.scala:183)
> at
> kafka.server.ReplicaFetcherThread.processPartitionData(ReplicaFetcherThread.scala:45)
> at
> kafka.server.AbstractFetcherThread$$anonfun$processFetchRequest$1$$anonfun$apply$mcV$sp$2.apply(AbstractFetcherThread.scala:130)
> ... 11 more
--
This message was sent by Atlassian JIRA
(v6.1.4#6159)
