You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Neha Narkhede (JIRA)" <ji...@apache.org> on 2013/12/11 20:29:07 UTC
[jira] [Resolved] (KAFKA-1178) Replica fetcher thread dies while
becoming follower
[ https://issues.apache.org/jira/browse/KAFKA-1178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Neha Narkhede resolved KAFKA-1178.
----------------------------------
Resolution: Fixed
Thanks for the reviews, committed the patch to trunk
> 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, KAFKA-1178_2013-12-11_11:09:09.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)