You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2020/10/21 02:19:42 UTC
[kafka] branch 2.6 updated: KAFKA-10564: fix flaky test (#9466)
This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.6 by this push:
new c4b41bc KAFKA-10564: fix flaky test (#9466)
c4b41bc is described below
commit c4b41bc725a635906ca6c400871a1c9de5dc4f26
Author: Michael Bingham <mi...@gmail.com>
AuthorDate: Tue Oct 20 20:16:23 2020 -0600
KAFKA-10564: fix flaky test (#9466)
Minor update to fix flaky state directory test by advancing the MockTime.
Reviewers: Chia-Ping Tsai <ch...@gmail.com>, A. Sophie Blee-Goldman <ab...@apache.org>
---
.../apache/kafka/streams/processor/internals/StateDirectoryTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
index 24c9ab0..5c7e678 100644
--- a/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/processor/internals/StateDirectoryTest.java
@@ -315,6 +315,7 @@ public class StateDirectoryTest {
assertEquals(1, directory.listNonEmptyTaskDirectories().length);
try (final LogCaptureAppender appender = LogCaptureAppender.createAndRegister(StateDirectory.class)) {
+ time.sleep(5000);
directory.cleanRemovedTasks(0);
assertTrue(dir.exists());
assertEquals(1, directory.listAllTaskDirectories().length);
@@ -326,6 +327,7 @@ public class StateDirectoryTest {
}
try (final LogCaptureAppender appender = LogCaptureAppender.createAndRegister(StateDirectory.class)) {
+ time.sleep(5000);
directory.cleanRemovedTasks(0);
assertTrue(dir.exists());
assertEquals(1, directory.listAllTaskDirectories().length);