Fix: Increase timeout to improve pipeline recovery during runtime age…

…nt downtime
data-integrations · Dec 24, 2024 · d47117c · d47117c
1 parent 92f7fcf
commit d47117c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/io/cdap/delta/bigquery/BigQueryEventConsumer.java b/src/main/java/io/cdap/delta/bigquery/BigQueryEventConsumer.java
@@ -228,8 +228,8 @@ public class BigQueryEventConsumer implements EventConsumer {
     this.schemaMappingCache = new SchemaMappingCache();
     this.commitRetryPolicy = new RetryPolicy<>()
       .withMaxAttempts(Integer.MAX_VALUE)
-      .withMaxDuration(Duration.of(5, ChronoUnit.MINUTES))
-      .withBackoff(1, 60, ChronoUnit.SECONDS)
+      .withMaxDuration(Duration.of(45, ChronoUnit.MINUTES))
+      .withBackoff(1, 180, ChronoUnit.SECONDS)
       .onFailedAttempt(failureContext -> {
         // log on the first failure and then every fifth failed attempt
         if (failureContext.getAttemptCount() == 1 || failureContext.getAttemptCount() % 5 == 0) {