diff --git a/src/pika_repl_bgworker.cc b/src/pika_repl_bgworker.cc index 1e12ffdf0a..39716635d5 100644 --- a/src/pika_repl_bgworker.cc +++ b/src/pika_repl_bgworker.cc @@ -126,7 +126,8 @@ void PikaReplBgWorker::HandleBGWorkerWriteBinlog(void* arg) { << " expected_session: " << binlog_res.session_id() << ", actual_session:" << slave_db->MasterSessionId(); LOG(WARNING) << "Check Session failed " << binlog_res.slot().db_name(); - slave_db->SetReplState(ReplState::kTryConnect); + // ignore expired task + // slave_db->SetReplState(ReplState::kTryConnect); return; }