[KAFKA-6228] Intermittent test failure in FetchRequestTest.testDownConversionWithConnectionFailure

• Type: Test
• Status: Resolved
• Priority: Minor
• Resolution: Cannot Reproduce
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 17/Nov/17 17:22
• Updated: 17/Feb/18 01:31
• Resolved: 17/Feb/18 01:31

Description

From https://builds.apache.org/job/kafka-trunk-jdk8/2219/testReport/junit/kafka.server/FetchRequestTest/testDownConversionWithConnectionFailure/ :

java.lang.AssertionError: Fetch size too small 42, broker may have run out of memory
	at org.junit.Assert.fail(Assert.java:88)
	at org.junit.Assert.assertTrue(Assert.java:41)
	at kafka.server.FetchRequestTest.kafka$server$FetchRequestTest$$fetch$1(FetchRequestTest.scala:214)
	at kafka.server.FetchRequestTest$$anonfun$testDownConversionWithConnectionFailure$2.apply(FetchRequestTest.scala:226)
	at kafka.server.FetchRequestTest$$anonfun$testDownConversionWithConnectionFailure$2.apply(FetchRequestTest.scala:226)
	at scala.collection.immutable.Range.foreach(Range.scala:160)
	at kafka.server.FetchRequestTest.testDownConversionWithConnectionFailure(FetchRequestTest.scala:226)

I ran FetchRequestTest locally which passed.

          assertTrue(s"Fetch size too small $size, broker may have run out of memory",
              size > maxPartitionBytes - batchSize)

The assertion message should include maxPartitionBytes and batchSize which would give us more information.