You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/08/13 09:00:13 UTC
[flink] 01/02: [FLINK-18815] Change Thread.sleep(2) to
Thread.sleep(0) to fail SafetyNetCloseableRegistryTest#testClose more often
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 27d5a3afa79e6be3d3d5a7583efca19a2174d2cb
Author: Kezhu Wang <ke...@gmail.com>
AuthorDate: Wed Aug 12 11:26:16 2020 +0800
[FLINK-18815] Change Thread.sleep(2) to Thread.sleep(0) to fail SafetyNetCloseableRegistryTest#testClose more often
---
.../java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-core/src/test/java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java b/flink-core/src/test/java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java
index ab14f77..fb1cc82 100644
--- a/flink-core/src/test/java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java
+++ b/flink-core/src/test/java/org/apache/flink/core/fs/AbstractCloseableRegistryTest.java
@@ -164,7 +164,7 @@ public abstract class AbstractCloseableRegistryTest<C extends Closeable, T> {
createAndRegisterStream();
try {
- Thread.sleep(2);
+ Thread.sleep(0);
} catch (InterruptedException ignored) {}
if (maxStreams != Integer.MAX_VALUE) {