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 <khachatryan.ro...@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(); } }