Commit 1f8b0752 authored by Kristian Nielsen's avatar Kristian Nielsen

Merge branch 'gtid_table_garbage_rows' into 10.1

parents bc2903e7 61bba2a5
...@@ -329,7 +329,9 @@ rpl_slave_state::update(uint32 domain_id, uint32 server_id, uint64 sub_id, ...@@ -329,7 +329,9 @@ rpl_slave_state::update(uint32 domain_id, uint32 server_id, uint64 sub_id,
} }
rgi->gtid_ignore_duplicate_state= rpl_group_info::GTID_DUPLICATE_NULL; rgi->gtid_ignore_duplicate_state= rpl_group_info::GTID_DUPLICATE_NULL;
#ifdef HAVE_REPLICATION
rgi->pending_gtid_deletes_clear(); rgi->pending_gtid_deletes_clear();
#endif
} }
if (!(list_elem= (list_element *)my_malloc(sizeof(*list_elem), MYF(MY_WME)))) if (!(list_elem= (list_element *)my_malloc(sizeof(*list_elem), MYF(MY_WME))))
...@@ -715,12 +717,16 @@ IF_DBUG(dbug_break:, ) ...@@ -715,12 +717,16 @@ IF_DBUG(dbug_break:, )
redundant rows in mysql.gtid_slave_pos may accumulate if transactions redundant rows in mysql.gtid_slave_pos may accumulate if transactions
are rolled back and retried after record_gtid(). are rolled back and retried after record_gtid().
*/ */
#ifdef HAVE_REPLICATION
rgi->pending_gtid_deletes_save(gtid->domain_id, elist); rgi->pending_gtid_deletes_save(gtid->domain_id, elist);
#endif
} }
else else
{ {
thd->mdl_context.release_transactional_locks(); thd->mdl_context.release_transactional_locks();
#ifdef HAVE_REPLICATION
rpl_group_info::pending_gtid_deletes_free(elist); rpl_group_info::pending_gtid_deletes_free(elist);
#endif
} }
} }
thd->lex->restore_backup_query_tables_list(&lex_backup); thd->lex->restore_backup_query_tables_list(&lex_backup);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment