diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index bc3cd4c2bfd..461c4a419be 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -6018,7 +6018,7 @@ finish: if (thd->is_error() || (thd->variables.option_bits & OPTION_MASTER_SQL_ERROR)) trans_rollback_stmt(thd); #ifdef WITH_WSREP - if (thd->spcont && + else if (thd->spcont && (thd->wsrep_conflict_state == MUST_ABORT || thd->wsrep_conflict_state == ABORTED || thd->wsrep_conflict_state == CERT_FAILURE))