diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc
index c8be6be541f..7fe8be00125 100644
--- a/sql/sql_parse.cc
+++ b/sql/sql_parse.cc
@@ -8431,13 +8431,11 @@ void wsrep_replication_process(THD *thd)
     break;
   }
 
-  if (thd->killed != KILL_CONNECTION)
-  {
-    mysql_mutex_lock(&LOCK_thread_count);
-    wsrep_close_applier(thd);
-    mysql_cond_broadcast(&COND_thread_count);
-    mysql_mutex_unlock(&LOCK_thread_count);
-  }
+  mysql_mutex_lock(&LOCK_thread_count);
+  wsrep_close_applier(thd);
+  mysql_cond_broadcast(&COND_thread_count);
+  mysql_mutex_unlock(&LOCK_thread_count);
+
   wsrep_return_from_bf_mode(thd, &shadow);
   DBUG_VOID_RETURN;
 }