Increase timeouts in CallTest to reduce flakiness (#33775)

apache · Jan 28, 2025 · 489e75e · 489e75e
1 parent b3dd0ad
commit 489e75e
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 4 deletions.
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java
@@ -198,7 +198,8 @@ public static void verifyDeterministic(Coder<?> target, String message, Iterable
     }
   }
 
-  public static <T> long getEncodedElementByteSizeUsingCoder(Coder<T> target, T value) throws Exception {
+  public static <T> long getEncodedElementByteSizeUsingCoder(Coder<T> target, T value)
+      throws Exception {
     return target.getEncodedElementByteSize(value);
   }
   /**

diff --git a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallTest.java b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallTest.java
@@ -358,7 +358,9 @@ private static class CallerExceedsTimeout implements Caller<Request, Response> {
     private final Duration timeout;
 
     CallerExceedsTimeout(Duration timeout) {
-      this.timeout = timeout.plus(Duration.standardSeconds(1L));
+      // The timeout testing is flaky so we set a sleep time with a minute padding beyond what
+      // should trigger the timeout.
+      this.timeout = timeout.plus(Duration.standardMinutes(1L));
     }
 
     @Override
@@ -397,7 +399,9 @@ private static class SetupExceedsTimeout implements SetupTeardown {
     private final Duration timeout;
 
     private SetupExceedsTimeout(Duration timeout) {
-      this.timeout = timeout.plus(Duration.standardSeconds(1L));
+      // The timeout testing is flaky so we set a sleep time with a minute padding beyond what
+      // should trigger the timeout.
+      this.timeout = timeout.plus(Duration.standardMinutes(1L));
     }
 
     @Override
@@ -443,7 +447,9 @@ private static class TeardownExceedsTimeout implements SetupTeardown {
     private final Duration timeout;
 
     private TeardownExceedsTimeout(Duration timeout) {
-      this.timeout = timeout.plus(Duration.standardSeconds(1L));
+      // The timeout testing is flaky so we set a sleep time with a minute padding beyond what
+      // should trigger the timeout.
+      this.timeout = timeout.plus(Duration.standardMinutes(1L));
     }
 
     @Override