diff --git a/be/src/storage/replication_txn_manager.cpp b/be/src/storage/replication_txn_manager.cpp index eafdbc5715b07..7ad4c1d4016ce 100644 --- a/be/src/storage/replication_txn_manager.cpp +++ b/be/src/storage/replication_txn_manager.cpp @@ -158,7 +158,9 @@ Status ReplicationTxnManager::remote_snapshot(const TRemoteSnapshotRequest& requ } std::vector missed_versions; - tablet->calc_missed_versions(request.src_visible_version, &missed_versions); + for (auto v = request.visible_version + 1; v <= request.src_visible_version; ++v) { + missed_versions.emplace_back(v, v); + } if (UNLIKELY(missed_versions.empty())) { LOG(WARNING) << "Remote snapshot tablet skipped, no missing version" << ", type: " << KeysType_Name(tablet->keys_type()) << ", txn_id: " << request.transaction_id