diff --git a/sql/slave.cc b/sql/slave.cc
index 31bd9372a14..68ddc611c03 100644
--- a/sql/slave.cc
+++ b/sql/slave.cc
@@ -4124,6 +4124,8 @@ static int exec_relay_log_event(THD* thd, Relay_log_info* rli,
 #ifdef WITH_WSREP
     if (wsrep_before_statement(thd))
     {
+      mysql_mutex_unlock(&rli->data_lock);
+      delete ev;
       WSREP_INFO("Wsrep before statement error");
       DBUG_RETURN(1);
     }