From 4a09fc4481fa645aaded6216eb7dbe1072ac7933 Mon Sep 17 00:00:00 2001 From: Vitaly Terentyev Date: Thu, 30 Jan 2025 18:19:47 +0400 Subject: [PATCH] Fix PreCommit Java IOs Direct job (#33813) * Fix timeout in rrio test * Fix mqtt read time --- .../test/java/org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 2 +- .../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 3ee6ed577a07..6c31b7f6ce58 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 void testReadWithMetadata() throws Exception { .withConnectionConfiguration( MqttIO.ConnectionConfiguration.create("tcp://localhost:" + port, wildcardTopic)) .withMaxNumRecords(10) - .withMaxReadTime(Duration.standardSeconds(5)); + .withMaxReadTime(Duration.standardSeconds(10)); final PCollection 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 b369a62ae78d..0e572bdd2d64 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 void givenCallerThrowsQuotaException_emitsIntoFailurePCollection() { @Test public void givenCallerTimeout_emitsFailurePCollection() { - Duration timeout = Duration.standardSeconds(1L); + Duration timeout = Duration.standardMinutes(1L); Result 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(