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;