(beam) branch master updated: Revert "Increase timeouts in CallTest to reduce flakiness (#33775)" (#33807)

[scwhittle]

This is an automated email from the ASF dual-hosted git repository.

scwhittle pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 5da82e7f307 Revert "Increase timeouts in CallTest to reduce flakiness 
(#33775)" (#33807)
5da82e7f307 is described below

commit 5da82e7f307498c2a0207c45f05ba23226f2fc16
Author: Yi Hu <ya...@google.com>
AuthorDate: Thu Jan 30 04:15:10 2025 -0500

    Revert "Increase timeouts in CallTest to reduce flakiness (#33775)" (#33807)
    
    This reverts commit 489e75e6c652c2f103c21e301abd5e1b4e882a95.
---
 .../core/src/main/java/org/apache/beam/sdk/coders/Coder.java |  3 +--
 .../java/org/apache/beam/io/requestresponse/CallTest.java    | 12 +++---------
 2 files changed, 4 insertions(+), 11 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
index 0a3650ca133..6bcdea0c0ab 100644
--- 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,8 +198,7 @@ public abstract class Coder<T> implements Serializable {
     }
   }
 
-  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
index b942e4207ae..b369a62ae78 100644
--- 
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,9 +358,7 @@ public class CallTest {
     private final Duration timeout;
 
     CallerExceedsTimeout(Duration timeout) {
-      // 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));
+      this.timeout = timeout.plus(Duration.standardSeconds(1L));
     }
 
     @Override
@@ -399,9 +397,7 @@ public class CallTest {
     private final Duration timeout;
 
     private SetupExceedsTimeout(Duration timeout) {
-      // 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));
+      this.timeout = timeout.plus(Duration.standardSeconds(1L));
     }
 
     @Override
@@ -447,9 +443,7 @@ public class CallTest {
     private final Duration timeout;
 
     private TeardownExceedsTimeout(Duration timeout) {
-      // 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));
+      this.timeout = timeout.plus(Duration.standardSeconds(1L));
     }
 
     @Override