kafka-commits mailing list archives

Repository: kafka
Updated Branches:
  refs/heads/trunk a3e13776e -> 4b3ea062b


KAFKA-4973; Fix transient failure of AdminClientTest.testDeleteRecordsWithException

Author: Dong Lin <lindong28@gmail.com>

Reviewers: Jiangjie Qin <becket.qin@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #2760 from lindong28/KAFKA-4973


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4b3ea062
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/4b3ea062
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/4b3ea062

Branch: refs/heads/trunk
Commit: 4b3ea062be515bc173f6c788c4c1e14f77935aef
Parents: a3e1377
Author: Dong Lin <lindong28@gmail.com>
Authored: Thu Mar 30 10:50:38 2017 -0700
Committer: Jiangjie Qin <becket.qin@gmail.com>
Committed: Thu Mar 30 10:50:38 2017 -0700

----------------------------------------------------------------------
 core/src/test/scala/integration/kafka/api/AdminClientTest.scala | 2 --
 1 file changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/4b3ea062/core/src/test/scala/integration/kafka/api/AdminClientTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/integration/kafka/api/AdminClientTest.scala b/core/src/test/scala/integration/kafka/api/AdminClientTest.scala
index c9ea05f..d9822cd 100644
--- a/core/src/test/scala/integration/kafka/api/AdminClientTest.scala
+++ b/core/src/test/scala/integration/kafka/api/AdminClientTest.scala
@@ -177,8 +177,6 @@ class AdminClientTest extends IntegrationTestHarness with Logging {
     assertEquals(DeleteRecordsResult(5L, null), client.deleteRecordsBefore(Map((tp, 5L))).get()(tp))
     // OffsetOutOfRangeException if offset > high_watermark
     assertEquals(DeleteRecordsResult(-1L, Errors.OFFSET_OUT_OF_RANGE.exception()), client.deleteRecordsBefore(Map((tp,
20))).get()(tp))
-    // TimeoutException if response is not available within user-specified timeout
-    assertEquals(DeleteRecordsResult(-1L, Errors.REQUEST_TIMED_OUT.exception()), client.deleteRecordsBefore(Map((tp,
5L))).get(0, TimeUnit.MILLISECONDS)(tp))
 
     val nonExistPartition = new TopicPartition(topic, 3)
     // UnknownTopicOrPartitionException if user tries to delete records of a non-existent
partition