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 2022/08/26 11:57:35 UTC
[flink] 01/03: [hotfix][tests] Use negative changelog materialization interval in tests
This is an automated email from the ASF dual-hosted git repository.
roman pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 258c3e35265bb3a966bd317340f2a5fe7cfd7364
Author: Roman Khachatryan <kh...@gmail.com>
AuthorDate: Wed Aug 24 18:20:02 2022 +0200
[hotfix][tests] Use negative changelog materialization interval in tests
...instead of a big value so that the subsequent change won't break them.
---
.../java/org/apache/flink/streaming/util/TestStreamEnvironment.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
index e9ec8314bf8..b56fdfe449c 100644
--- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
+++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java
@@ -138,8 +138,7 @@ public class TestStreamEnvironment extends StreamExecutionEnvironment {
Duration.ofMillis(500),
Duration.ofSeconds(1),
Duration.ofSeconds(5),
- Duration.ofSeconds(
- Long.MAX_VALUE / 1000 /* max allowed by Duration.toMillis */));
+ Duration.ofSeconds(-1));
miniCluster.overrideRestoreModeForChangelogStateBackend();
}
}