diff options
Diffstat (limited to 'sql/wsrep_hton.cc')
| -rw-r--r-- | sql/wsrep_hton.cc | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/sql/wsrep_hton.cc b/sql/wsrep_hton.cc index 0e013556f45..576e6b8ad47 100644 --- a/sql/wsrep_hton.cc +++ b/sql/wsrep_hton.cc @@ -178,6 +178,7 @@ int wsrep_commit(handlerton *hton, THD *thd, bool all) extern Rpl_filter* binlog_filter; extern my_bool opt_log_slave_updates; +extern void wsrep_write_rbr_buf(THD *thd, const void* rbr_buf, size_t buf_len); enum wsrep_trx_status wsrep_run_wsrep_commit( THD *thd, handlerton *hton, bool all) @@ -337,6 +338,10 @@ wsrep_run_wsrep_commit( (thd->wsrep_PA_safe) ? WSREP_FLAG_PA_SAFE : 0ULL, &thd->wsrep_trx_seqno); if (rcode == WSREP_TRX_MISSING) { + WSREP_WARN("Transaction missing in provider, thd: %ld, SQL: %s", + thd->thread_id, thd->query()); + wsrep_write_rbr_buf(thd, rbr_data, data_len); + rcode = WSREP_OK; } else if (rcode == WSREP_BF_ABORT) { mysql_mutex_lock(&thd->LOCK_wsrep_thd); |