From d47117c213d49bc42e8b1062e42f60d68bcbaed6 Mon Sep 17 00:00:00 2001
From: Anshuman <anshumanks@google.com>
Date: Tue, 24 Dec 2024 17:07:51 +0530
Subject: [PATCH] Fix: Increase timeout to improve pipeline recovery during
 runtime agent downtime

---
 .../java/io/cdap/delta/bigquery/BigQueryEventConsumer.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/io/cdap/delta/bigquery/BigQueryEventConsumer.java b/src/main/java/io/cdap/delta/bigquery/BigQueryEventConsumer.java
index 9e1f0fb..66b329b 100644
--- 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) {