summaryrefslogtreecommitdiff
path: root/sql/rpl_parallel.cc
diff options
context:
space:
mode:
authorOleksandr Byelkin <sanja@mariadb.com>2023-01-28 18:22:55 +0100
committerOleksandr Byelkin <sanja@mariadb.com>2023-01-28 18:22:55 +0100
commita977054ee0bd1601a5252ec02459bac0241d9bfc (patch)
treefa5d780bbdcd977294e519e6890fa2ea48436f8c /sql/rpl_parallel.cc
parent765291d63e0c2a10c513a354e9ecb2e905570775 (diff)
parentc73985f2ce8a391582787f3e310a011c1a712bec (diff)
downloadmariadb-git-a977054ee0bd1601a5252ec02459bac0241d9bfc.tar.gz
Merge branch '10.3' into 10.4
Diffstat (limited to 'sql/rpl_parallel.cc')
-rw-r--r--sql/rpl_parallel.cc3
1 files changed, 1 insertions, 2 deletions
diff --git a/sql/rpl_parallel.cc b/sql/rpl_parallel.cc
index 2c431ccc12d..8701fc19411 100644
--- a/sql/rpl_parallel.cc
+++ b/sql/rpl_parallel.cc
@@ -56,8 +56,7 @@ rpt_handle_event(rpl_parallel_thread::queued_event *qev,
rgi->event_relay_log_pos= qev->event_relay_log_pos;
rgi->future_event_relay_log_pos= qev->future_event_relay_log_pos;
strcpy(rgi->future_event_master_log_name, qev->future_event_master_log_name);
- if (!(ev->is_artificial_event() || ev->is_relay_log_event() ||
- (ev->when == 0)))
+ if (event_can_update_last_master_timestamp(ev))
rgi->last_master_timestamp= ev->when + (time_t)ev->exec_time;
err= apply_event_and_update_pos_for_parallel(ev, thd, rgi);