[beam] branch master updated: Set MIN_PER_PARTITION_MEMORY to 10 MiB instead of 4 MiB to match the change in the backend limit. (#28964)

[jr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jrmccluskey pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 47d0fd566f8 Set MIN_PER_PARTITION_MEMORY to 10 MiB instead of 4 MiB to match the change in the backend limit. (#28964)
47d0fd566f8 is described below

commit 47d0fd566f86aaad35d26709c52ee555381823a4
Author: dpcollins-google <40...@users.noreply.github.com>
AuthorDate: Fri Oct 13 14:20:10 2023 -0400

    Set MIN_PER_PARTITION_MEMORY to 10 MiB instead of 4 MiB to match the change in the backend limit. (#28964)
---
 .../apache/beam/sdk/io/gcp/pubsublite/internal/SubscribeTransform.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/pubsublite/internal/SubscribeTransform.java b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscribeTransform.java
index f3ffbb13c24..882294de177 100644
--- a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscribeTransform.java
+++ b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscribeTransform.java
@@ -56,7 +56,7 @@ public class SubscribeTransform extends PTransform<PBegin, PCollection<Sequenced
 
   private static final long MEBIBYTE = 1L << 20;
   private static final long SOFT_MEMORY_LIMIT = 512 * MEBIBYTE;
-  private static final long MIN_PER_PARTITION_MEMORY = 4 * MEBIBYTE;
+  private static final long MIN_PER_PARTITION_MEMORY = 10 * MEBIBYTE;
   private static final long MAX_PER_PARTITION_MEMORY = 100 * MEBIBYTE;
 
   private static final MemoryLimiter LIMITER =