Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2054 Fix Kafka transient unit test failures
  3. KAFKA-3876

Transient test failure: kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions

    XMLWordPrintableJSON

    Details

      Description

      Failed in a recent build:

      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)
      

      Standard out:

      [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)
      

      https://jenkins.confluent.io/job/kafka-trunk/932/

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              ijuma Ismael Juma
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: