fix: adjust thresholds in tests

googleapis · Jul 29, 2024 · 9fdbf3d · 9fdbf3d
1 parent 05c8cbe
commit 9fdbf3d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java
@@ -436,7 +436,7 @@ public void testLargeMessagesDoNotReorderBatches() throws Exception {
                 Publisher.Builder.DEFAULT_BATCHING_SETTINGS
                     .toBuilder()
                     .setElementCountThreshold(10L)
-                    .setRequestByteThreshold(20L)
+                    .setRequestByteThreshold(64L)
                     .setDelayThreshold(Duration.ofSeconds(100))
                     .build())
             .setEnableMessageOrdering(true)
@@ -1139,7 +1139,7 @@ public void testPublishFlowControl_throwException() throws Exception {
                             .setLimitExceededBehavior(
                                 FlowController.LimitExceededBehavior.ThrowException)
                             .setMaxOutstandingElementCount(1L)
-                            .setMaxOutstandingRequestBytes(10L)
+                            .setMaxOutstandingRequestBytes(55L)
                             .build())
                     .build())
             .build();
@@ -1181,7 +1181,7 @@ public void testPublishFlowControl_throwExceptionWithOrderingKey() throws Except
                             .setLimitExceededBehavior(
                                 FlowController.LimitExceededBehavior.ThrowException)
                             .setMaxOutstandingElementCount(1L)
-                            .setMaxOutstandingRequestBytes(10L)
+                            .setMaxOutstandingRequestBytes(55L)
                             .build())
                     .build())
             .setEnableMessageOrdering(true)
@@ -1227,7 +1227,7 @@ public void testPublishFlowControl_block() throws Exception {
                         FlowControlSettings.newBuilder()
                             .setLimitExceededBehavior(FlowController.LimitExceededBehavior.Block)
                             .setMaxOutstandingElementCount(2L)
-                            .setMaxOutstandingRequestBytes(10L)
+                            .setMaxOutstandingRequestBytes(55L)
                             .build())
                     .build())
             .build();