From add69e9297f4780a8d89baec0b21d2798042fd8a Mon Sep 17 00:00:00 2001 From: utsav-pal <159793156+utsav-pal@users.noreply.github.com> Date: Sun, 7 Sep 2025 23:47:17 +0530 Subject: [PATCH] Update default max publish batch byte size calculation --- .../main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java index 8daa40514e83..dd5961b0555e 100644 --- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java +++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java @@ -1348,7 +1348,7 @@ public abstract static class Write extends PTransform, PDone> * Max batch byte size. Messages are base64 encoded which encodes each set of three bytes into * four bytes. */ - private static final int MAX_PUBLISH_BATCH_BYTE_SIZE_DEFAULT = ((10 * 1000 * 1000) / 4) * 3; + private static final int MAX_PUBLISH_BATCH_BYTE_SIZE_DEFAULT = 10 * 1000 * 1000 ; private static final int MAX_PUBLISH_BATCH_SIZE = 100;