master_pos_wait is now OK to return NULL. We only care if it returns with -1
This commit is contained in:
parent
079f1c0f98
commit
ec34a5ef75
2
build.sh
2
build.sh
@ -1,7 +1,7 @@
|
|||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
#
|
#
|
||||||
#
|
#
|
||||||
RELEASE_VERSION="0.7.4"
|
RELEASE_VERSION="0.7.5"
|
||||||
|
|
||||||
buildpath=/tmp/gh-ost
|
buildpath=/tmp/gh-ost
|
||||||
target=gh-ost
|
target=gh-ost
|
||||||
|
@ -552,7 +552,7 @@ func (this *Applier) StopSlaveIOThread() error {
|
|||||||
// MasterPosWait is applicable with --test-on-replica
|
// MasterPosWait is applicable with --test-on-replica
|
||||||
func (this *Applier) MasterPosWait(binlogCoordinates *mysql.BinlogCoordinates) error {
|
func (this *Applier) MasterPosWait(binlogCoordinates *mysql.BinlogCoordinates) error {
|
||||||
var appliedRows int64
|
var appliedRows int64
|
||||||
if err := this.db.QueryRow(`select master_pos_wait(?, ?, ?)`, binlogCoordinates.LogFile, binlogCoordinates.LogPos, 1).Scan(&appliedRows); err != nil {
|
if err := this.db.QueryRow(`select ifnull(master_pos_wait(?, ?, ?), 0)`, binlogCoordinates.LogFile, binlogCoordinates.LogPos, 1).Scan(&appliedRows); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if appliedRows < 0 {
|
if appliedRows < 0 {
|
||||||
|
Loading…
Reference in New Issue
Block a user