Set MIN_PER_PARTITION_MEMORY to 10 MiB instead of 4 MiB to match the …

…change in the backend limit. (apache#28964)
JayajP · Oct 13, 2023 · 47d0fd5 · 47d0fd5
1 parent 250483c
commit 47d0fd5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...form/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscribeTransform.java b/...form/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 =