From e8b384e43c0b1dd9cbc8be79b749ad3508d2f25c Mon Sep 17 00:00:00 2001 From: Shlomi Noach Date: Wed, 28 Jun 2017 19:35:55 +0300 Subject: [PATCH 1/2] supporting greater batch size --- go/base/context.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/go/base/context.go b/go/base/context.go index d82b22e..d779dc8 100644 --- a/go/base/context.go +++ b/go/base/context.go @@ -47,6 +47,7 @@ const ( const ( HTTPStatusOK = 200 + maxBatchSize = 5000 ) var ( @@ -441,8 +442,8 @@ func (this *MigrationContext) SetDMLBatchSize(batchSize int64) { if batchSize < 1 { batchSize = 1 } - if batchSize > 100 { - batchSize = 100 + if batchSize > maxBatchSize { + batchSize = maxBatchSize } atomic.StoreInt64(&this.DMLBatchSize, batchSize) } From 095863b7741a210d09c852f2341e38defe9bd393 Mon Sep 17 00:00:00 2001 From: Shlomi Noach Date: Tue, 4 Jul 2017 08:50:25 +0300 Subject: [PATCH 2/2] dml-batch-size capped at 1000 --- go/base/context.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/go/base/context.go b/go/base/context.go index d779dc8..beb5475 100644 --- a/go/base/context.go +++ b/go/base/context.go @@ -47,7 +47,7 @@ const ( const ( HTTPStatusOK = 200 - maxBatchSize = 5000 + maxBatchSize = 1000 ) var (