diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index c37b555ae52..91b8ec138a0 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -3814,7 +3814,7 @@ mysql_execute_command(THD *thd) #ifdef WITH_WSREP /* Check wsrep_mode rules before command execution. */ - if (WSREP(thd) && + if (WSREP_NNULL(thd) && wsrep_thd_is_local(thd) && !wsrep_check_mode_before_cmd_execute(thd)) goto error;