You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2024/03/27 09:04:21 UTC
(flink) 01/02: [FLINK-26615][tests] Assert only the minimum delay in RetryingExecutorTest.testTimeout
This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit fc60d176e3ad7f06a93ebb37da491737f196fbe6
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Tue Mar 26 18:00:03 2024 +0100
[FLINK-26615][tests] Assert only the minimum delay in RetryingExecutorTest.testTimeout
---
.../test/java/org/apache/flink/changelog/fs/RetryingExecutorTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/RetryingExecutorTest.java b/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/RetryingExecutorTest.java
index 614c4284413..eb204b0ac98 100644
--- a/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/RetryingExecutorTest.java
+++ b/flink-dstl/flink-dstl-dfs/src/test/java/org/apache/flink/changelog/fs/RetryingExecutorTest.java
@@ -219,7 +219,7 @@ class RetryingExecutorTest {
Executors.newScheduledThreadPool(2));
/* future completion can be delayed arbitrarily causing start delta be less than timeout */
assertThat(((double) secondStart.get() - firstStart.get()) / 1_000_000)
- .isCloseTo(timeout, Percentage.withPercentage(75));
+ .isGreaterThanOrEqualTo(timeout * .75);
}
private void testPolicy(