(beam) branch master updated: Fix PreCommit Java IOs Direct job (#33813)

[xqhu]

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

xqhu 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 4a09fc4481f Fix PreCommit Java IOs Direct job (#33813)
4a09fc4481f is described below

commit 4a09fc4481fa645aaded6216eb7dbe1072ac7933
Author: Vitaly Terentyev <vitaly.terent...@akvelon.com>
AuthorDate: Thu Jan 30 18:19:47 2025 +0400

    Fix PreCommit Java IOs Direct job (#33813)
    
    * Fix timeout in rrio test
    
    * Fix mqtt read time
---
 .../mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java  | 2 +-
 .../src/test/java/org/apache/beam/io/requestresponse/CallTest.java  | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java 
b/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java
index 3ee6ed577a0..6c31b7f6ce5 100644
--- 
a/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java
+++ 
b/sdks/java/io/mqtt/src/test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java
@@ -216,7 +216,7 @@ public class MqttIOTest {
             .withConnectionConfiguration(
                 MqttIO.ConnectionConfiguration.create("tcp://localhost:" + 
port, wildcardTopic))
             .withMaxNumRecords(10)
-            .withMaxReadTime(Duration.standardSeconds(5));
+            .withMaxReadTime(Duration.standardSeconds(10));
 
     final PCollection<MqttRecord> output = 
pipeline.apply(mqttReaderWithMetadata);
     PAssert.that(output)
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 b369a62ae78..0e572bdd2d6 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
@@ -123,7 +123,7 @@ public class CallTest {
 
   @Test
   public void givenCallerTimeout_emitsFailurePCollection() {
-    Duration timeout = Duration.standardSeconds(1L);
+    Duration timeout = Duration.standardMinutes(1L);
     Result<Response> result =
         pipeline
             .apply(Create.of(new Request("a")))
@@ -182,7 +182,7 @@ public class CallTest {
 
   @Test
   public void givenSetupTimeout_throwsError() {
-    Duration timeout = Duration.standardSeconds(1L);
+    Duration timeout = Duration.standardMinutes(1L);
 
     pipeline
         .apply(Create.of(new Request("")))
@@ -231,7 +231,7 @@ public class CallTest {
 
   @Test
   public void givenTeardownTimeout_throwsError() {
-    Duration timeout = Duration.standardSeconds(1L);
+    Duration timeout = Duration.standardMinutes(1L);
     pipeline
         .apply(Create.of(new Request("")))
         .apply(