diff --git a/go/vt/binlog/binlogplayer/dbclient.go b/go/vt/binlog/binlogplayer/dbclient.go
index c3463b4cc2c..e37b069bd9a 100644
--- a/go/vt/binlog/binlogplayer/dbclient.go
+++ b/go/vt/binlog/binlogplayer/dbclient.go
@@ -107,7 +107,6 @@ func (dc *dbClientImpl) Commit() error {
 	_, err := dc.dbConn.ExecuteFetch("commit", 1, false)
 	if err != nil {
 		LogError("COMMIT failed w/ error", err)
-		dc.dbConn.Close()
 	}
 	return err
 }