diff --git a/migration/migrate.go b/migration/migrate.go index 490ee3a..19e6c81 100644 --- a/migration/migrate.go +++ b/migration/migrate.go @@ -129,7 +129,7 @@ func InitMigration(mConfig *MigrationConfig) error { zlogger.Logger.Error(err) return err } - mConfig.ChunkSize = dStorageService.GetChunkWriteSize() + mConfig.ChunkSize = int64(mConfig.ChunkNumber) * dStorageService.GetChunkWriteSize() zlogger.Logger.Info("Getting aws storage service") awsStorageService, err := s3.GetAwsClient( mConfig.Bucket,