You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ishita Mandhan (JIRA)" <ji...@apache.org> on 2016/07/05 18:48:11 UTC
[jira] [Comment Edited] (KAFKA-3876) Transient test failure:
kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions
[ https://issues.apache.org/jira/browse/KAFKA-3876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362993#comment-15362993 ]
Ishita Mandhan edited comment on KAFKA-3876 at 7/5/16 6:48 PM:
---------------------------------------------------------------
I saw the error in testPatternSubscription too - https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/4559/
was (Author: imandhan):
I saw a similar one too - https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/4559/
> Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions
> ---------------------------------------------------------------------------------------
>
> Key: KAFKA-3876
> URL: https://issues.apache.org/jira/browse/KAFKA-3876
> Project: Kafka
> Issue Type: Sub-task
> Components: unit tests
> Reporter: Ismael Juma
> Labels: transient-unit-test-failure
>
> Failed in a recent build:
> {code}
> java.lang.AssertionError: Partition [__consumer_offsets,0] metadata not propagated after 5000 ms
> at org.junit.Assert.fail(Assert.java:88)
> at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:771)
> at kafka.utils.TestUtils$.waitUntilMetadataIsPropagated(TestUtils.scala:812)
> at kafka.utils.TestUtils$$anonfun$createTopic$1.apply(TestUtils.scala:240)
> at kafka.utils.TestUtils$$anonfun$createTopic$1.apply(TestUtils.scala:239)
> at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.immutable.Range.foreach(Range.scala:160)
> at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at kafka.utils.TestUtils$.createTopic(TestUtils.scala:239)
> at kafka.api.IntegrationTestHarness$class.setUp(IntegrationTestHarness.scala:80)
> at kafka.api.BaseConsumerTest.setUp(BaseConsumerTest.scala:60)
> {code}
> Standard out:
> {code}
> [2016-06-19 09:09:20,081] WARN Client session timed out, have not heard from server in 4002ms for sessionid 0x15567ebcc160001 (org.apache.zookeeper.ClientCnxn:1108)
> [2016-06-19 09:09:21,602] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160001, likely client has closed socket
> at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
> at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> at java.lang.Thread.run(Thread.java:745)
> [2016-06-19 09:09:20,081] WARN Client session timed out, have not heard from server in 4001ms for sessionid 0x15567ebcc160003 (org.apache.zookeeper.ClientCnxn:1108)
> [2016-06-19 09:09:21,598] WARN Client session timed out, have not heard from server in 4001ms for sessionid 0x15567ebcc160002 (org.apache.zookeeper.ClientCnxn:1108)
> [2016-06-19 09:09:21,613] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160003, likely client has closed socket
> at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
> at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> at java.lang.Thread.run(Thread.java:745)
> [2016-06-19 09:09:21,613] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160002, likely client has closed socket
> at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
> at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> at java.lang.Thread.run(Thread.java:745)
> [2016-06-19 09:09:21,602] WARN Client session timed out, have not heard from server in 4084ms for sessionid 0x15567ebcc160000 (org.apache.zookeeper.ClientCnxn:1108)
> [2016-06-19 09:09:21,615] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15567ebcc160000, likely client has closed socket
> at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
> at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> at java.lang.Thread.run(Thread.java:745)
> [2016-06-19 09:11:26,866] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15567edb4d10002, likely client has closed socket
> at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
> at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> at java.lang.Thread.run(Thread.java:745)
> [2016-06-19 09:11:29,171] ERROR [KafkaApi-0] Error when handling request Name: FetchRequest; Version: 2; CorrelationId: 0; ClientId: ReplicaFetcherThread-0-0; ReplicaId: 2; MaxWait: 500 ms; MinBytes: 1 bytes; RequestInfo: [__consumer_offsets,0] -> PartitionFetchInfo(0,1048576) (kafka.server.KafkaApis:103)
> kafka.common.NotAssignedReplicaException: Leader 0 failed to record follower 2's position -1 since the replica is not recognized to be one of the assigned replicas for partition [__consumer_offsets,0].
> at kafka.cluster.Partition.updateReplicaLogReadResult(Partition.scala:251)
> at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:864)
> at kafka.server.ReplicaManager$$anonfun$updateFollowerLogReadResults$2.apply(ReplicaManager.scala:861)
> at scala.collection.immutable.Map$Map1.foreach(Map.scala:116)
> at kafka.server.ReplicaManager.updateFollowerLogReadResults(ReplicaManager.scala:861)
> at kafka.server.ReplicaManager.fetchMessages(ReplicaManager.scala:470)
> at kafka.server.KafkaApis.handleFetchRequest(KafkaApis.scala:496)
> at kafka.server.KafkaApis.handle(KafkaApis.scala:77)
> at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:60)
> at java.lang.Thread.run(Thread.java:745)
> [2016-06-19 09:11:29,171] ERROR [ReplicaFetcherThread-0-0], Error for partition [__consumer_offsets,0] to broker 0:org.apache.kafka.common.errors.UnknownServerException: The server experienced an unexpected error when processing the request (kafka.server.ReplicaFetcherThread:97)
> [2016-06-19 09:11:47,714] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:357)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15567ee0b4c0002, likely client has closed socket
> at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
> at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> at java.lang.Thread.run(Thread.java:745)
> {code}
> https://jenkins.confluent.io/job/kafka-trunk/932/
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)