Skip to content

Commit 94d47b9

Browse files
committed
Decrease max batch byte size to 128 mb
1 parent 05144f9 commit 94d47b9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

airbyte-integrations/connectors/destination-snowflake/src/main/java/io/airbyte/integrations/destination/snowflake/SnowflakeInternalStagingConsumerFactory.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public class SnowflakeInternalStagingConsumerFactory {
4646

4747
private static final Logger LOGGER = LoggerFactory.getLogger(SnowflakeInternalStagingConsumerFactory.class);
4848

49-
private static final long MAX_BATCH_SIZE_BYTES = 1024 * 1024 * 1024 / 4; // 256mb
49+
private static final long MAX_BATCH_SIZE_BYTES = 128 * 1024 * 1024; // 128mb
5050
private final String CURRENT_SYNC_PATH = UUID.randomUUID().toString();
5151

5252
public AirbyteMessageConsumer create(final Consumer<AirbyteMessage> outputRecordCollector,

0 commit comments

Comments
 (0)