fix settings

PeerDB-io · May 20, 2024 · 430729f · 430729f
1 parent 36c2f7b
commit 430729f
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 12 deletions.
diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go
@@ -25,12 +25,13 @@ import (
 )
 
 const (
-	PeerDBClickhouseQueryMaxMemoryUsage              int = 0
-	PeerDBClickhouseMaxBlockSize                     int = 10240
-	PeerDBClickhouseMaxInsertBlockSize               int = 10240
-	PeerDBClickhouseMaxInsertThreads                 int = 2
-	PeerDBClickhouseMemoryOvercommitRatioDenominator int = 0
-	PeerDBClickhouseMaxMemoryUsageForUser            int = 0
+	PeerDBClickhouseQueryMaxMemoryUsage                  int = 64000000000
+	PeerDBClickhouseMaxBlockSize                         int = 10240
+	PeerDBClickhouseMaxInsertBlockSize                   int = 10240
+	PeerDBClickhouseMaxInsertThreads                     int = 1
+	PeerDBClickhouseMemoryOvercommitRatioDenominator     int = 0
+	PeerDBClickhouseMemoryOvercommitRatioDenominatorUser int = 0
+	PeerDBClickhouseMaxMemoryUsageForUser                int = 64000000000
 )
 
 type ClickhouseConnector struct {

diff --git a/flow/connectors/clickhouse/qrep_avro_sync.go b/flow/connectors/clickhouse/qrep_avro_sync.go
@@ -20,12 +20,13 @@ import (
 )
 
 var ClickhouseQuerySettings = clickhouse.Settings{
-	"max_memory_usage":                    PeerDBClickhouseQueryMaxMemoryUsage,
-	"max_block_size":                      PeerDBClickhouseMaxBlockSize,
-	"max_insert_block_size":               PeerDBClickhouseMaxInsertBlockSize,
-	"max_insert_threads":                  PeerDBClickhouseMaxInsertThreads,
-	"memory_overcommit_ratio_denominator": PeerDBClickhouseMemoryOvercommitRatioDenominator,
-	"max_memory_usage_for_user":           PeerDBClickhouseMaxMemoryUsageForUser,
+	"max_memory_usage":                             PeerDBClickhouseQueryMaxMemoryUsage,
+	"max_block_size":                               PeerDBClickhouseMaxBlockSize,
+	"max_insert_block_size":                        PeerDBClickhouseMaxInsertBlockSize,
+	"max_insert_threads":                           PeerDBClickhouseMaxInsertThreads,
+	"memory_overcommit_ratio_denominator":          PeerDBClickhouseMemoryOvercommitRatioDenominator,
+	"memory_overcommit_ratio_denominator_for_user": PeerDBClickhouseMemoryOvercommitRatioDenominatorUser,
+	"max_memory_usage_for_user":                    PeerDBClickhouseMaxMemoryUsageForUser,
 }
 
 type ClickhouseAvroSyncMethod struct {