fix upgrade (#3787)

Co-authored-by: Doodle <13706157+critical27@users.noreply.github.com>
vesoft-inc · Jan 26, 2022 · f5713d3 · f5713d3
1 parent 2df456f
commit f5713d3
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/tools/db-upgrade/DbUpgrader.cpp b/src/tools/db-upgrade/DbUpgrader.cpp
@@ -910,13 +910,17 @@ void UpgraderSpace::runPartV3() {
  }
  return;
  }
+ int64_t ingestFileCount = 0;
  auto write_sst = [&, this](const std::vector<kvstore::KV>& data) {
  ::rocksdb::Options option;
  option.create_if_missing = true;
  option.compression = ::rocksdb::CompressionType::kNoCompression;
  ::rocksdb::SstFileWriter sst_file_writer(::rocksdb::EnvOptions(), option);
- std::string file = ::fmt::format(
- ".nebula_upgrade.space-{}.part-{}.{}.sst", spaceId_, partId, std::time(nullptr));
+ std::string file = ::fmt::format(".nebula_upgrade.space-{}.part-{}-{}-{}.sst",
+ spaceId_,
+ partId,
+ ingestFileCount++,
+ std::time(nullptr));
  ::rocksdb::Status s = sst_file_writer.Open(file);
  if (!s.ok()) {
  LOG(FATAL) << "Faild upgrade V3 of space " << spaceId_ << ", part " << partId << ":"