We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 683faba commit 989fa54Copy full SHA for 989fa54
1 file changed
pkg/outputs/mysql/mysql.go
@@ -139,8 +139,12 @@ func (output *MySQLOutput) Start() error {
139
}
140
141
func (output *MySQLOutput) Close() {
142
- output.db.Close()
143
- output.targetSchemaStore.Close()
+ if output.db != nil {
+ output.db.Close()
144
+ }
145
+ if output.targetSchemaStore != nil {
146
+ output.targetSchemaStore.Close()
147
148
149
150
func (output *MySQLOutput) GetRouter() core.Router {
0 commit comments