Merge pull request #192 from github/row-copy-complete

avoiding writing rows when rowcopy complete
This commit is contained in:
Shlomi Noach 2016-08-26 08:27:49 +02:00 committed by GitHub
commit 59967d53a3
2 changed files with 5 additions and 1 deletions

View File

@ -2,7 +2,7 @@
# #
# #
RELEASE_VERSION="1.0.13" RELEASE_VERSION="1.0.14"
function build { function build {
osname=$1 osname=$1

View File

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