diff options
| -rw-r--r-- | sql/wsrep_applier.cc | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/sql/wsrep_applier.cc b/sql/wsrep_applier.cc index b9c259f7b5e..e10c19287c4 100644 --- a/sql/wsrep_applier.cc +++ b/sql/wsrep_applier.cc @@ -365,8 +365,10 @@ wsrep_cb_status_t wsrep_commit_cb(void* const ctx, else rcode = wsrep_rollback(thd); + /* Cleanup */ wsrep_set_apply_format(thd, NULL); thd->mdl_context.release_transactional_locks(); + thd->reset_query(); /* Mutex protected */ free_root(thd->mem_root,MYF(MY_KEEP_PREALLOC)); thd->tx_isolation= (enum_tx_isolation) thd->variables.tx_isolation; |