[incubator-pegasus] branch master updated: feat(bulk_load): set move_files as true while ingest files (#864)

[yu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yuchenhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git


The following commit(s) were added to refs/heads/master by this push:
     new 3fb7505  feat(bulk_load): set move_files as true while ingest files (#864)
3fb7505 is described below

commit 3fb750534c3f69221bdcecffcbce7900e83e25db
Author: HeYuchen <he...@xiaomi.com>
AuthorDate: Wed Jan 5 18:30:12 2022 +0800

    feat(bulk_load): set move_files as true while ingest files (#864)
---
 src/server/rocksdb_wrapper.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/server/rocksdb_wrapper.cpp b/src/server/rocksdb_wrapper.cpp
index 2974693..a6db999 100644
--- a/src/server/rocksdb_wrapper.cpp
+++ b/src/server/rocksdb_wrapper.cpp
@@ -183,6 +183,7 @@ void rocksdb_wrapper::clear_up_write_batch() { _write_batch->Clear(); }
 int rocksdb_wrapper::ingestion_files(int64_t decree, const std::vector<std::string> &sst_file_list)
 {
     rocksdb::IngestExternalFileOptions ifo;
+    ifo.move_files = true;
     rocksdb::Status s = _db->IngestExternalFile(sst_file_list, ifo);
     if (dsn_unlikely(!s.ok())) {
         derror_rocksdb("IngestExternalFile", s.ToString(), "decree = {}", decree);

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org