1 files changed, 8 insertions, 0 deletions
diff --git a/sql/sql_class.cc b/sql/sql_class.cc
index 348dd488d2a..14821f0e027 100644
--- a/sql/sql_class.cc
+++ b/sql/sql_class.cc
@@ -1484,6 +1484,14 @@ void THD::init(void)
   wsrep_bf_thd = NULL;
   wsrep_TOI_pre_query     = NULL;
   wsrep_TOI_pre_query_len = 0;
+
+  /*
+    @@wsrep_causal_reads is now being handled via wsrep_sync_wait, update it
+    appropriately.
+  */
+  if (variables.wsrep_causal_reads)
+    variables.wsrep_sync_wait|= WSREP_SYNC_WAIT_BEFORE_READ;
+
 #endif
   if (variables.sql_log_bin)
     variables.option_bits|= OPTION_BIN_LOG;