From fef6bb09236d2a450466d306825b06665819a955 Mon Sep 17 00:00:00 2001 From: Jie Yao Date: Sun, 1 Sep 2024 04:02:16 -0700 Subject: [PATCH] fix error --- src/lib/replication/repl_dev/raft_repl_dev.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/lib/replication/repl_dev/raft_repl_dev.cpp b/src/lib/replication/repl_dev/raft_repl_dev.cpp index 6b044231f..c44b1e797 100644 --- a/src/lib/replication/repl_dev/raft_repl_dev.cpp +++ b/src/lib/replication/repl_dev/raft_repl_dev.cpp @@ -130,8 +130,8 @@ folly::SemiFuture< ReplServiceError > RaftReplDev::destroy_group() { // here, we set the dsn to a new one , which is definitely unique in the follower, so that the new rreq will not // have a conflict with the old rreq. - rreq->init(repl_key{.dsn = m_next_dsn.fetch_add(1)}, journal_type_t::HS_CTRL_DESTROY, true, sisl::blob{}, - sisl::blob{}, 0); + rreq->init(repl_key{.server_id = server_id(), .term = raft_server()->get_term(), .dsn = m_next_dsn.fetch_add(1)}, + journal_type_t::HS_CTRL_DESTROY, true, sisl::blob{}, sisl::blob{}, 0); auto err = m_state_machine->propose_to_raft(std::move(rreq)); if (err != ReplServiceError::OK) {