kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lind...@apache.org
Subject [kafka] branch trunk updated: MINOR: Fix LogDirFailureTest flake
Date Mon, 08 Oct 2018 21:08:18 GMT
This is an automated email from the ASF dual-hosted git repository.

lindong pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 6165b43  MINOR: Fix LogDirFailureTest flake
6165b43 is described below

commit 6165b43744bf9df9d4bda577f11db75b704a6ac5
Author: Gardner Vickers <gardner@vickers.me>
AuthorDate: Mon Oct 8 14:07:56 2018 -0700

    MINOR: Fix LogDirFailureTest flake
    
    Ensure that `TestUtils.waitUntilTrue(..)` is blocked on both send completed and a new
leader being assigned
    
    Author: Gardner Vickers <gardner@vickers.me>
    
    Reviewers: Dhruvil Shah <dhruvil@confluent.io>, Dong Lin <lindong28@gmail.com>
    
    Closes #5695 from gardnervickers/log-dir-failure-test-fix
---
 core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala b/core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala
index aaf6477..4709282 100644
--- a/core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala
+++ b/core/src/test/scala/unit/kafka/server/LogDirFailureTest.scala
@@ -178,13 +178,15 @@ class LogDirFailureTest extends IntegrationTestHarness {
         }
     }
 
-    // Wait for producer to update metadata for the partition
     TestUtils.waitUntilTrue(() => {
       // ProduceResponse may contain KafkaStorageException and trigger metadata update
       producer.send(record)
       producer.partitionsFor(topic).asScala.find(_.partition() == 0).get.leader().id() !=
leaderServerId
     }, "Expected new leader for the partition", 6000L)
 
+    // Block on send to ensure that new leader accepts a message.
+    producer.send(record).get(6000L, TimeUnit.MILLISECONDS)
+
     // Consumer should receive some messages
     TestUtils.waitUntilTrue(() => {
       consumer.poll(0).count() > 0


Mime
View raw message