From e603831fd8271c8680bc4f2bd09976db00da2c7c Mon Sep 17 00:00:00 2001 From: Chia-Ping Tsai Date: Tue, 17 Mar 2020 00:29:08 +0800 Subject: [PATCH] Minor: fix flaky StateDirectoryTest.shouldOnlyListNonEmptyTaskDirectories --- .../streams/processor/internals/StateDirectoryTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 827557a88faae..5a1ad27a69c92 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 @@ -36,6 +36,7 @@ import java.nio.file.StandardOpenOption; import java.util.Arrays; import java.util.Collections; +import java.util.HashSet; import java.util.List; import java.util.Objects; import java.util.Properties; @@ -315,12 +316,12 @@ public void shouldOnlyListNonEmptyTaskDirectories() { final File storeDir = new File(taskDir1, "store"); assertTrue(storeDir.mkdir()); - assertEquals(Arrays.asList(taskDir1, taskDir2), Arrays.asList(directory.listAllTaskDirectories())); + assertEquals(new HashSet<>(Arrays.asList(taskDir1, taskDir2)), new HashSet<>(Arrays.asList(directory.listAllTaskDirectories()))); assertEquals(Collections.singletonList(taskDir1), Arrays.asList(directory.listNonEmptyTaskDirectories())); directory.cleanRemovedTasks(0L); - assertEquals(Arrays.asList(taskDir1, taskDir2), Arrays.asList(directory.listAllTaskDirectories())); + assertEquals(new HashSet<>(Arrays.asList(taskDir1, taskDir2)), new HashSet<>(Arrays.asList(directory.listAllTaskDirectories()))); assertEquals(Collections.emptyList(), Arrays.asList(directory.listNonEmptyTaskDirectories())); }