tweaks

Change-Id: Ic7027670c7bffdffa569218bb771218c5a689f54
googleapis · Dec 11, 2023 · 39bb429 · 39bb429
1 parent 74c43ef
commit 39bb429
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/ReadIT.java b/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/it/ReadIT.java
@@ -64,6 +64,7 @@
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.junit.runners.JUnit4;
+import org.threeten.bp.Duration;
 
 @RunWith(JUnit4.class)
 public class ReadIT {
@@ -322,7 +323,7 @@ public void reversed() {
   }
 
   @Test
-  public void reversedWithFocedResumption() throws IOException, InterruptedException {
+  public void reversedWithForcedResumption() throws IOException, InterruptedException {
     assume()
         .withMessage("reverse scans are not supported in the emulator")
         .that(testEnvRule.env())
@@ -363,6 +364,10 @@ public void reversedWithFocedResumption() throws IOException, InterruptedExcepti
     BigtableDataSettings.Builder settingsBuilder =
         testEnvRule.env().getDataClientSettings().toBuilder();
 
+    settingsBuilder.stubSettings().readRowsSettings().retrySettings()
+            .setInitialRpcTimeout(Duration.ofMillis(10))
+            .setMaxAttempts(100);
+
     InstantiatingGrpcChannelProvider.Builder transport =
         ((InstantiatingGrpcChannelProvider)
                 settingsBuilder.stubSettings().getTransportChannelProvider())
@@ -398,9 +403,9 @@ public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
         for (Row row :
             patchedClient.readRows(Query.create(tableId).prefix(uniqueKey).reversed(true))) {
           actualResults.add(row);
+          Thread.sleep(1);
         }
         assertThat(actualResults).containsExactlyElementsIn(expectedResults).inOrder();
-        Thread.sleep(10);
       }
     }
   }