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
The following commit(s) were added to refs/heads/release-1.15 by this push: new ddec8d8e144 [FLINK-27169][tests] Increase changelog upload timeout in PartiallyFinishedSourcesITCase ddec8d8e144 is described below commit ddec8d8e144c9cc9adb0a04f41c9667cdd68aabb Author: Roman Khachatryan <khachatryan.ro...@gmail.com> AuthorDate: Sat Feb 25 22:43:44 2023 +0000 [FLINK-27169][tests] Increase changelog upload timeout in PartiallyFinishedSourcesITCase --- .../runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java b/flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java index eec2eebcc96..54ef5d6411d 100644 --- a/flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java +++ b/flink-tests/src/test/java/org/apache/flink/runtime/operators/lifecycle/PartiallyFinishedSourcesITCase.java @@ -40,6 +40,7 @@ import org.junit.runner.RunWith; import org.junit.runners.Parameterized; import org.junit.runners.Parameterized.Parameter; +import java.time.Duration; import java.util.ArrayList; import java.util.Iterator; import java.util.List; @@ -48,6 +49,8 @@ import static java.util.Arrays.asList; import static java.util.stream.StreamSupport.stream; import static org.apache.flink.api.common.restartstrategy.RestartStrategies.fixedDelayRestart; import static org.apache.flink.changelog.fs.FsStateChangelogOptions.BASE_PATH; +import static org.apache.flink.changelog.fs.FsStateChangelogOptions.RETRY_MAX_ATTEMPTS; +import static org.apache.flink.changelog.fs.FsStateChangelogOptions.UPLOAD_TIMEOUT; import static org.apache.flink.changelog.fs.FsStateChangelogStorageFactory.IDENTIFIER; import static org.apache.flink.configuration.JobManagerOptions.EXECUTION_FAILOVER_STRATEGY; import static org.apache.flink.configuration.StateChangelogOptions.STATE_CHANGE_LOG_STORAGE; @@ -92,6 +95,8 @@ public class PartiallyFinishedSourcesITCase extends TestLogger { // can only be set on the cluster level; so we do it unconditionally here. configuration.setString(STATE_CHANGE_LOG_STORAGE, IDENTIFIER); configuration.setString(BASE_PATH, TEMPORARY_FOLDER.newFolder().getAbsolutePath()); + configuration.set(RETRY_MAX_ATTEMPTS, 10); + configuration.set(UPLOAD_TIMEOUT, Duration.ofMinutes(1)); miniClusterResource = new MiniClusterWithClientResource(