increase max queue size to 30000

airbytehq · May 20, 2024 · f3da96c · f3da96c
1 parent 471c8b3
commit f3da96c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresUtils.java b/.../source-postgres/src/main/java/io/airbyte/integrations/source/postgres/PostgresUtils.java
@@ -49,7 +49,7 @@ public class PostgresUtils {
   public static final Duration DEFAULT_SUBSEQUENT_RECORD_WAIT_TIME = Duration.ofMinutes(1);
 
   private static final int MIN_QUEUE_SIZE = 1000;
-  private static final int MAX_QUEUE_SIZE = 10000;
+  private static final int MAX_QUEUE_SIZE = 30000;
 
   private static final String DROP_AGGREGATE_IF_EXISTS_STATEMENT = "DROP aggregate IF EXISTS EPHEMERAL_HEARTBEAT(float4)";
   private static final String CREATE_AGGREGATE_STATEMENT = "CREATE AGGREGATE EPHEMERAL_HEARTBEAT(float4) (SFUNC = float4pl, STYPE = float4)";