diff --git a/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java b/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java
index 748e1edc..1b41560d 100644
--- a/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/src/main/java/com/google/cloud/flink/bigquery/integration/BigQueryIntegrationTest.java
+++ b/flink-1.17-connector-bigquery/flink-connector-bigquery-integration-test/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