diff options
| -rw-r--r-- | sql/sql_parse.cc | 1 | ||||
| -rw-r--r-- | sql/wsrep_thd.cc | 1 |
2 files changed, 2 insertions, 0 deletions
diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index 42ad69d84ec..f1a3e7cb58e 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -7016,6 +7016,7 @@ static void wsrep_mysql_parse(THD *thd, char *rawbuf, uint length, /* Performance Schema Interface instrumentation, end */ MYSQL_END_STATEMENT(thd->m_statement_psi, thd->get_stmt_da()); thd->m_statement_psi= NULL; + thd->m_digest= NULL; close_thread_tables(thd); thd->wsrep_conflict_state= RETRY_AUTOCOMMIT; diff --git a/sql/wsrep_thd.cc b/sql/wsrep_thd.cc index d898c982b1d..776a640cabe 100644 --- a/sql/wsrep_thd.cc +++ b/sql/wsrep_thd.cc @@ -214,6 +214,7 @@ void wsrep_replay_transaction(THD *thd) */ MYSQL_END_STATEMENT(thd->m_statement_psi, thd->get_stmt_da()); thd->m_statement_psi= NULL; + thd->m_digest= NULL; thd_proc_info(thd, "wsrep replaying trx"); WSREP_DEBUG("replay trx: %s %lld", thd->query() ? thd->query() : "void", |