summaryrefslogtreecommitdiff
path: root/sql/log.cc
diff options
context:
space:
mode:
authorNirbhay Choubey <nirbhay@mariadb.com>2015-04-21 13:22:08 -0400
committerNirbhay Choubey <nirbhay@mariadb.com>2015-05-08 17:43:57 -0400
commite69fbd4e38d36853b7e72a9d6a3afe7210874436 (patch)
tree0ac55db490d05c516d15ece4bea397e0a730a4ec /sql/log.cc
parent3331d4e07efca993b3f34fa06b8a03b41b6b690d (diff)
downloadmariadb-git-e69fbd4e38d36853b7e72a9d6a3afe7210874436.tar.gz
Post-merge fix
Diffstat (limited to 'sql/log.cc')
-rw-r--r--sql/log.cc10
1 files changed, 9 insertions, 1 deletions
diff --git a/sql/log.cc b/sql/log.cc
index 8ea84ac189d..f042b1ab756 100644
--- a/sql/log.cc
+++ b/sql/log.cc
@@ -569,7 +569,15 @@ void thd_binlog_trx_reset(THD * thd)
{
binlog_cache_mngr *const cache_mngr=
(binlog_cache_mngr*) thd_get_ha_data(thd, binlog_hton);
- if (cache_mngr) cache_mngr->reset(false, true);
+ if (cache_mngr)
+ {
+ cache_mngr->reset(false, true);
+ if (!cache_mngr->stmt_cache.empty())
+ {
+ WSREP_DEBUG("pending events in stmt cache, sql: %s", thd->query());
+ cache_mngr->stmt_cache.reset();
+ }
+ }
}
thd->clear_binlog_table_maps();
}