gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Ensure we force moves not copies when ingesting bulk insert files

Browse Source
This commit is contained in:
John Sully 2022-05-04 16:51:48 +00:00
parent ec6378767d
commit a6ab09cf7b
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/rocksdb.cpp
View File

@ -74,8 +74,8 @@ void RocksDBStorageProvider::bulkInsert(char **rgkeys, size_t *rgcbkeys, char **
auto ingestOptions = rocksdb::IngestExternalFileOptions(); auto ingestOptions = rocksdb::IngestExternalFileOptions();
ingestOptions.move_files = true; ingestOptions.move_files = true;
//ingestOptions.verify_file_checksum = false;
ingestOptions.write_global_seqno = false; ingestOptions.write_global_seqno = false;
ingestOptions.failed_move_fall_back_to_copy = false;
// Ingest the external SST file into the DB // Ingest the external SST file into the DB
s = m_spdb->IngestExternalFile(m_spcolfamily.get(), {file_path}, ingestOptions); s = m_spdb->IngestExternalFile(m_spcolfamily.get(), {file_path}, ingestOptions);
@ -83,8 +83,6 @@ void RocksDBStorageProvider::bulkInsert(char **rgkeys, size_t *rgcbkeys, char **
unlink(file_path.c_str()); unlink(file_path.c_str());
goto LFallback; goto LFallback;
} }
unlink(file_path.c_str());
} else { } else {
LFallback: LFallback:
auto spbatch = std::make_unique<rocksdb::WriteBatch>(); auto spbatch = std::make_unique<rocksdb::WriteBatch>();