Merge pull request #271 from data-integrations/recovery-timeout-impro…

…vement

Fix: Increase timeout to improve pipeline recovery during runtime agent downtime

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) {