diff --git a/go/base/context.go b/go/base/context.go
index a9008ae1b..41baae696 100644
--- a/go/base/context.go
+++ b/go/base/context.go
@@ -772,7 +772,7 @@ func (this *MigrationContext) ReadMaxLoad(maxLoadList string) error {
 	return nil
 }
 
-// ReadMaxLoad parses the `--max-load` flag, which is in multiple key-value format,
+// ReadCriticalLoad parses the `--max-load` flag, which is in multiple key-value format,
 // such as: 'Threads_running=100,Threads_connected=500'
 // It only applies changes in case there's no parsing error.
 func (this *MigrationContext) ReadCriticalLoad(criticalLoadList string) error {
diff --git a/go/logic/applier.go b/go/logic/applier.go
index fa374a70f..9b190919f 100644
--- a/go/logic/applier.go
+++ b/go/logic/applier.go
@@ -796,7 +796,7 @@ func (this *Applier) StartSlaveIOThread() error {
 	return nil
 }
 
-// StartSlaveSQLThread is applicable with --test-on-replica
+// StopSlaveSQLThread is applicable with --test-on-replica
 func (this *Applier) StopSlaveSQLThread() error {
 	query := `stop /* gh-ost */ slave sql_thread`
 	this.migrationContext.Log.Infof("Verifying SQL thread is stopped")
diff --git a/go/logic/throttler.go b/go/logic/throttler.go
index 9c8dcfc0c..5b5d231fd 100644
--- a/go/logic/throttler.go
+++ b/go/logic/throttler.go
@@ -284,7 +284,7 @@ func (this *Throttler) criticalLoadIsMet() (met bool, variableName string, value
 	return false, variableName, value, threshold, nil
 }
 
-// collectReplicationLag reads the latest changelog heartbeat value
+// collectThrottleHTTPStatus reads the latest changelog heartbeat value
 func (this *Throttler) collectThrottleHTTPStatus(firstThrottlingCollected chan<- bool) {
 	collectFunc := func() (sleep bool, err error) {
 		if atomic.LoadInt64(&this.migrationContext.HibernateUntil) > 0 {