Skip to content

Commit 8e6f943

Browse files
authored
fix: increase sample row key default timeout for beam (#4567)
Change-Id: I004f0881e24600e14a37cf62a78b8e341edc70ed
1 parent 3cbf0be commit 8e6f943

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

bigtable-dataflow-parent/bigtable-hbase-beam/src/main/java/com/google/cloud/bigtable/batch/common/CloudBigtableServiceImpl.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration;
2525
import com.google.cloud.bigtable.hbase.wrappers.veneer.BigtableHBaseVeneerSettings;
2626
import java.io.IOException;
27+
import java.time.Duration;
2728
import java.util.List;
2829

2930
/** For internal use only - public for technical reasons. */
@@ -52,6 +53,15 @@ public List<KeyOffset> getSampleRowKeys(CloudBigtableTableConfiguration config)
5253
.setPreemptiveRefreshEnabled(false)
5354
.build())
5455
.build());
56+
57+
builder
58+
.stubSettings()
59+
.sampleRowKeysSettings()
60+
.retrySettings()
61+
.setInitialRpcTimeoutDuration(Duration.ofMinutes(20))
62+
.setMaxRpcTimeoutDuration(Duration.ofMinutes(20))
63+
.setTotalTimeoutDuration(Duration.ofMinutes(20));
64+
5565
try (BigtableDataClient client = BigtableDataClient.create(builder.build())) {
5666
return client.sampleRowKeys(config.getTableId());
5767
}

0 commit comments

Comments
 (0)