Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-431

LogCorruptionTest.testMessageSizeTooLarge fails occasionally

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.0
    • Component/s: core

      Description

      It fails with the following exception:

      [info] Test Starting: testMessageSizeTooLarge(kafka.log.LogCorruptionTest)
      [2012-07-31 15:54:57,525] ERROR KafkaApi on Broker 0, Error while retrieving topic metadata (kafka.server.KafkaApis:99)
      java.lang.NullPointerException
      at scala.util.parsing.combinator.Parsers$NoSuccess.<init>(Parsers.scala:131)
      at scala.util.parsing.combinator.Parsers$Failure.<init>(Parsers.scala:158)
      at scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:489)
      at scala.util.parsing.combinator.Parsers$$anonfun$acceptIf$1.apply(Parsers.scala:487)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1$$anonfun$apply$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Failure.append(Parsers.scala:162)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Success.flatMapWithNext(Parsers.scala:113)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$flatMap$1.apply(Parsers.scala:200)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$map$1.apply(Parsers.scala:203)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$Parser$$anonfun$append$1.apply(Parsers.scala:208)
      at scala.util.parsing.combinator.Parsers$$anon$3.apply(Parsers.scala:182)
      at scala.util.parsing.combinator.Parsers$$anon$2.apply(Parsers.scala:742)
      at scala.util.parsing.json.JSON$.parseRaw(JSON.scala:71)
      at scala.util.parsing.json.JSON$.parseFull(JSON.scala:85)
      at kafka.utils.ZkUtils$$anonfun$getPartitionAssignmentForTopics$1.apply(ZkUtils.scala:461)
      at kafka.utils.ZkUtils$$anonfun$getPartitionAssignmentForTopics$1.apply(ZkUtils.scala:456)
      at scala.collection.Iterator$class.foreach(Iterator.scala:631)
      at scala.collection.LinearSeqLike$$anon$1.foreach(LinearSeqLike.scala:52)
      at kafka.utils.ZkUtils$.getPartitionAssignmentForTopics(ZkUtils.scala:456)
      at kafka.admin.AdminUtils$$anonfun$getTopicMetaDataFromZK$1.apply(AdminUtils.scala:93)
      at kafka.admin.AdminUtils$$anonfun$getTopicMetaDataFromZK$1.apply(AdminUtils.scala:91)
      at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
      at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206)
      at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
      at scala.collection.immutable.List.foreach(List.scala:45)
      at scala.collection.TraversableLike$class.map(TraversableLike.scala:206)
      at scala.collection.immutable.List.map(List.scala:45)
      at kafka.admin.AdminUtils$.getTopicMetaDataFromZK(AdminUtils.scala:91)
      at kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:433)
      at kafka.server.KafkaApis$$anonfun$handleTopicMetadataRequest$1.apply(KafkaApis.scala:423)
      at scala.collection.LinearSeqOptimized$class.foreach(LinearSeqOptimized.scala:61)
      at scala.collection.immutable.List.foreach(List.scala:45)
      at kafka.server.KafkaApis.handleTopicMetadataRequest(KafkaApis.scala:422)
      at kafka.server.KafkaApis.handle(KafkaApis.scala:61)
      at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:38)
      at java.lang.Thread.run(Thread.java:662)

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              junrao Jun Rao
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: