From 9452a29f48903695a943bf4e6dbde754531a0422 Mon Sep 17 00:00:00 2001 From: Mattie Fu Date: Tue, 13 Feb 2024 13:14:19 -0500 Subject: [PATCH] fix: temporarily double idle timeout to workaround a bug in watchdog (#30299) --- .../beam/sdk/io/gcp/bigtable/BigtableConfigTranslator.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfigTranslator.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfigTranslator.java index 02273f8334dc..7484d84782d0 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfigTranslator.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfigTranslator.java @@ -321,7 +321,12 @@ private static BigtableDataSettings configureReadSettings( .setRpcTimeoutMultiplier(1) .setTotalTimeout(Duration.ofMillis(Math.max(initialRpcTimeout, totalTimeout))); - settings.stubSettings().readRowsSettings().setWaitTimeout(Duration.ofMillis(waitTimeout)); + settings + .stubSettings() + .readRowsSettings() + .setWaitTimeout(Duration.ofMillis(waitTimeout)) + // Temporarily doubles the idle timeout to work around a bug in gax watchdog + .setIdleTimeout(Duration.ofMinutes(10)); settings.stubSettings().readRowsSettings().setRetrySettings(retrySettings.build());