diff --git a/qan/analyzer/mysql/mysql.go b/qan/analyzer/mysql/mysql.go
index 0274a5de..21baade6 100644
--- a/qan/analyzer/mysql/mysql.go
+++ b/qan/analyzer/mysql/mysql.go
@@ -143,6 +143,7 @@ func (m *MySQLAnalyzer) Start() error {
 		m.clock,
 		m.spool,
 	)
+	m.restartChan = restartChan
 
 	return m.analyzer.Start()
 }