fix test max num records

apache · Nov 5, 2024 · f37b6b3 · f37b6b3
1 parent d5fce0d
commit f37b6b3
Showing 1 changed file with 1 addition and 3 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
@@ -289,11 +289,9 @@ public void testReadWithMultipleTopics() throws Exception {
             .withConnectionConfiguration(
                 MqttIO.ConnectionConfiguration.createWithMultipleTopics(
                     "tcp://localhost:" + port, Arrays.asList(topic1, topic2)))
-            .withMaxNumRecords(15)
-            .withMaxReadTime(Duration.standardSeconds(5));
+            .withMaxNumRecords(10);
 
     final PCollection<MqttRecord> output = pipeline.apply(mqttReaderWithTopicArray);
-
     PAssert.that(output)
         .satisfies(
             iter -> {