diff --git a/go/base/context.go b/go/base/context.go
index d82b22e..beb5475 100644
--- a/go/base/context.go
+++ b/go/base/context.go
@@ -47,6 +47,7 @@ const (
 
 const (
 	HTTPStatusOK = 200
+	maxBatchSize = 1000
 )
 
 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)
 }