From 9ca1cb5687bf3be21719155b6fc50f16cef98591 Mon Sep 17 00:00:00 2001 From: tarikceric Date: Mon, 6 Jan 2025 20:26:15 -0800 Subject: [PATCH] reduce batch size --- .../streamline/core/realtime/streamline__blocks_tx_realtime.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/models/streamline/core/realtime/streamline__blocks_tx_realtime.sql b/models/streamline/core/realtime/streamline__blocks_tx_realtime.sql index a4a5fd8..67078b3 100644 --- a/models/streamline/core/realtime/streamline__blocks_tx_realtime.sql +++ b/models/streamline/core/realtime/streamline__blocks_tx_realtime.sql @@ -6,7 +6,7 @@ params ={ "external_table" :"blocks_tx_v2", "sql_limit" :"1200000", "producer_batch_size" :"300000", - "worker_batch_size" :"50000", + "worker_batch_size" :"25000", "sql_source" :"{{this.identifier}}", "order_by_column": "block_number" } ),