avoiding writing rows when rowcopy complete

This commit is contained in:
Shlomi Noach 2016-08-23 14:26:47 +02:00
parent 1021a83ac0
commit 56d09c4105

View File

@ -1146,6 +1146,10 @@ func (this *Migrator) iterateChunks() error {
return nil
}
copyRowsFunc := func() error {
if atomic.LoadInt64(&this.rowCopyCompleteFlag) == 1 {
// Done
return nil
}
hasFurtherRange, err := this.applier.CalculateNextIterationRangeEndValues()
if err != nil {
return terminateRowIteration(err)