diff --git a/pkg/util/mysql/mysql.go b/pkg/util/mysql/mysql.go
index 84c433de2..38645dfbd 100644
--- a/pkg/util/mysql/mysql.go
+++ b/pkg/util/mysql/mysql.go
@@ -187,7 +187,7 @@ func (conn *Connection) Grant(username string, password string, database string,
 		database = "*"
 	}
 	{
-		sql := fmt.Sprintf("CREATE USER '%s'@'%s' IDENTIFIED BY '%s'", username, address, password)
+		sql := fmt.Sprintf("CREATE USER IF NOT EXISTS '%s'@'%s' IDENTIFIED BY '%s'", username, address, password)
 		_, err := conn.db.Exec(sql)
 		if err != nil {
 			return errors.Wrap(err, sql)
@@ -199,6 +199,7 @@ func (conn *Connection) Grant(username string, password string, database string,
 		if err != nil {
 			return errors.Wrap(err, sql)
 		}
+		conn.db.Exec("FLUSH PRIVILEGES")
 	}
 	return nil
 }