moar debugging

ferry.go

@@ -880,6 +880,7 @@ func (f *Ferry) WaitUntilBinlogStreamerCatchesUp() {
 // You will know that the BinlogStreamer finished when .Run() returns.
 func (f *Ferry) FlushBinlogAndStopStreaming() {
 	if f.WaitUntilReplicaIsCaughtUpToMaster != nil {
+		f.logger.Info("flush binlog and stop streaming: wait until replica is caught up to master")
 		isReplica, err := CheckDbIsAReplica(f.WaitUntilReplicaIsCaughtUpToMaster.MasterDB)
 		if err != nil {
 			f.ErrorHandler.Fatal("wait_replica", err)

test/lib/go/integrationferry/ferry.go

@@ -148,11 +148,14 @@ func (f *IntegrationFerry) Main() error {
 		return err
 	}
 
+	f.logger.Debug("flush binlog and stop streaming")
 	// TODO: this method should return errors rather than calling
 	// the error handler to panic directly.
 	f.FlushBinlogAndStopStreaming()
+	f.logger.Debug("wait for Ferry to exit")
 	wg.Wait()
 
+	f.logger.Debug("finished waiting")
 	if f.Verifier != nil {
 		err := f.SendStatusAndWaitUntilContinue(StatusVerifyDuringCutover)
 		if err != nil {