[flink] branch release-1.15 updated: [FLINK-27169][tests] Increase changelog upload timeout in PartiallyFinishedSourcesITCase

[roman]

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(