From a24d17011c886ef66a099972d76ee2962f9839e2 Mon Sep 17 00:00:00 2001 From: Ismael Juma Date: Fri, 24 Nov 2017 14:28:50 +0000 Subject: [PATCH] MINOR: Temporarily disable testLogStartOffsetCheckpoint It's failing often and it seems like there are multiple reasons. PR #4238 will re-enable it. --- .../integration/kafka/api/AdminClientIntegrationTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala b/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala index 1490a822bc4e7..0676a1a32637b 100644 --- a/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala +++ b/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala @@ -38,7 +38,7 @@ import org.apache.kafka.common.{KafkaFuture, TopicPartition, TopicPartitionRepli import org.apache.kafka.common.acl._ import org.apache.kafka.common.config.ConfigResource import org.apache.kafka.common.errors._ -import org.junit.{After, Before, Rule, Test} +import org.junit.{After, Before, Ignore, Rule, Test} import org.apache.kafka.common.requests.{DeleteRecordsRequest, MetadataResponse} import org.apache.kafka.common.resource.{Resource, ResourceType} import org.junit.rules.Timeout @@ -47,6 +47,7 @@ import org.junit.Assert._ import scala.util.Random import scala.collection.JavaConverters._ import java.lang.{Long => JLong} + import scala.concurrent.duration.Duration import scala.concurrent.{Await, Future} @@ -732,6 +733,7 @@ class AdminClientIntegrationTest extends IntegrationTestHarness with Logging { } @Test + @Ignore // Disabled temporarily until flakiness is resolved def testLogStartOffsetCheckpoint(): Unit = { TestUtils.createTopic(zkUtils, topic, 2, serverCount, servers)