Fix restart strategy in e2e test (#181)

GoogleCloudDataproc · Nov 4, 2024 · 089cdf2 · 089cdf2
1 parent fbb0b4d
commit 089cdf2
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...st/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java b/...st/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java
@@ -176,7 +176,8 @@ public class BigQueryIntegrationTest {
     private static final Integer MAX_OUT_OF_ORDER = 10;
     private static final Integer MAX_IDLENESS = 20;
     private static final RestartStrategyConfiguration RESTART_STRATEGY =
-            RestartStrategies.fixedDelayRestart(5, Time.seconds(10L));
+            RestartStrategies.exponentialDelayRestart(
+                    Time.seconds(5), Time.minutes(10), 2.0, Time.hours(2), 0);
 
     public static void main(String[] args) throws Exception {
         // parse input arguments