Fix PreCommit Java IOs Direct job (#33813)

* Fix timeout in rrio test * Fix mqtt read time
apache · Jan 30, 2025 · 4a09fc4 · 4a09fc4
1 parent d121703
commit 4a09fc4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -216,7 +216,7 @@ public void testReadWithMetadata() throws Exception {
             .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
@@ -123,7 +123,7 @@ public void givenCallerThrowsQuotaException_emitsIntoFailurePCollection() {
 
   @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 void givenSetupThrowsQuotaException_throwsError() {
 
   @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 void givenTeardownThrowsQuotaException_throwsError() {
 
   @Test
   public void givenTeardownTimeout_throwsError() {
-    Duration timeout = Duration.standardSeconds(1L);
+    Duration timeout = Duration.standardMinutes(1L);
     pipeline
         .apply(Create.of(new Request("")))
         .apply(