Repository: kafka Updated Branches: refs/heads/trunk 0bc2d0e02 -> 49b773bfc
MINOR: Temporarily disable testLogStartOffsetCheckpoint It's failing often and it seems like there are multiple reasons. PR #4238 will re-enable it. Author: Ismael Juma <[email protected]> Reviewers: Rajini Sivaram <[email protected]> Closes #4262 from ijuma/temporarily-disable-test-log-start-offset-checkpoint Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/49b773bf Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/49b773bf Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/49b773bf Branch: refs/heads/trunk Commit: 49b773bfc814ac9606419c0e8dfdc877dc4ba99b Parents: 0bc2d0e Author: Ismael Juma <[email protected]> Authored: Fri Nov 24 18:02:52 2017 +0000 Committer: Ismael Juma <[email protected]> Committed: Fri Nov 24 18:02:52 2017 +0000 ---------------------------------------------------------------------- .../scala/integration/kafka/api/AdminClientIntegrationTest.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/49b773bf/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala b/core/src/test/scala/integration/kafka/api/AdminClientIntegrationTest.scala index 1490a82..0676a1a 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)
