summaryrefslogtreecommitdiff
path: root/sql/rpl_parallel.cc
diff options
context:
space:
mode:
authorOleksandr Byelkin <sanja@mariadb.com>2023-01-26 10:34:26 +0100
committerOleksandr Byelkin <sanja@mariadb.com>2023-01-26 10:34:26 +0100
commitdd24fa3063e29eb9308eebb3e3471e8fd3fd5ef7 (patch)
tree479d0b186b75361bb714a10ca8b080a35e176f6d /sql/rpl_parallel.cc
parent765291d63e0c2a10c513a354e9ecb2e905570775 (diff)
parent2279dddad6bea00c5774a76f410c11fd56ad168f (diff)
downloadmariadb-git-dd24fa3063e29eb9308eebb3e3471e8fd3fd5ef7.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);