kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-6012) NoSuchElementException in markErrorMeter during TransactionsBounceTest
Date Thu, 05 Oct 2017 16:28:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16193136#comment-16193136
] 

ASF GitHub Bot commented on KAFKA-6012:
---------------------------------------

Github user asfgit closed the pull request at:

    https://github.com/apache/kafka/pull/4024


> NoSuchElementException in markErrorMeter during TransactionsBounceTest
> ----------------------------------------------------------------------
>
>                 Key: KAFKA-6012
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6012
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Ismael Juma
>            Assignee: Rajini Sivaram
>            Priority: Blocker
>             Fix For: 1.0.0, 1.1.0
>
>
> I think this is probably a test issue, but setting as "Blocker" until we can confirm
that.
> {code}
> Error
> org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for output-topic-0:
10467 ms has passed since batch creation plus linger time
> Stacktrace
> org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for output-topic-0:
10467 ms has passed since batch creation plus linger time
> Standard Output
> [2017-10-05 00:29:31,327] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-05 00:29:31,877] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0]
Error for partition input-topic-0 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:
This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101)
> [2017-10-05 00:29:31,877] ERROR [ReplicaFetcher replicaId=3, leaderId=1, fetcherId=0]
Error for partition input-topic-0 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:
This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101)
> [2017-10-05 00:29:31,877] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0]
Error for partition input-topic-1 to broker %2:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:
This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101)
> [2017-10-05 00:29:32,268] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0]
Error for partition output-topic-1 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:
This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101)
> [2017-10-05 00:29:32,284] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0]
Error for partition output-topic-1 to broker %1:org.apache.kafka.common.errors.UnknownTopicOrPartitionException:
This server does not host this topic-partition. (kafka.server.ReplicaFetcherThread:101)
> [2017-10-05 00:29:44,283] ERROR [KafkaApi-0] Error when handling request {controller_id=0,controller_epoch=1,delete_partitions=false,partitions=[{topic=input-topic,partition=1}]}
(kafka.server.KafkaApis:107)
> java.util.NoSuchElementException: key not found: NONE
> 	at scala.collection.MapLike$class.default(MapLike.scala:228)
> 	at scala.collection.AbstractMap.default(Map.scala:59)
> 	at scala.collection.mutable.HashMap.apply(HashMap.scala:65)
> 	at kafka.network.RequestMetrics.markErrorMeter(RequestChannel.scala:410)
> 	at kafka.network.RequestChannel$$anonfun$updateErrorMetrics$1.apply(RequestChannel.scala:315)
> 	at kafka.network.RequestChannel$$anonfun$updateErrorMetrics$1.apply(RequestChannel.scala:314)
> 	at scala.collection.Iterator$class.foreach(Iterator.scala:891)
> 	at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
> 	at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> 	at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 	at kafka.network.RequestChannel.updateErrorMetrics(RequestChannel.scala:314)
> 	at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$sendResponse$1.apply(KafkaApis.scala:2092)
> 	at kafka.server.KafkaApis$$anonfun$kafka$server$KafkaApis$$sendResponse$1.apply(KafkaApis.scala:2092)
> 	at scala.Option.foreach(Option.scala:257)
> 	at kafka.server.KafkaApis.kafka$server$KafkaApis$$sendResponse(KafkaApis.scala:2092)
> 	at kafka.server.KafkaApis.sendResponseExemptThrottle(KafkaApis.scala:2061)
> 	at kafka.server.KafkaApis.handleStopReplicaRequest(KafkaApis.scala:202)
> 	at kafka.server.KafkaApis.handle(KafkaApis.scala:104)
> 	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:65)
> {code}
> https://builds.apache.org/blue/organizations/jenkins/kafka-trunk-jdk8/detail/kafka-trunk-jdk8/2106/tests



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message