Method MarkPendingMetadataReset

be/src/catalog/catalog-server.cc:1005–1027

}

void CatalogServer::MarkPendingMetadataReset(const unique_lock<std::mutex>& lock) {
  DCHECK(lock.mutex() == &catalog_lock_ && lock.owns_lock())
      << "Must hold catalog_lock_ to avoid concurrency with TriggerResetMetadata thread";
  long current_catalog_resets;
  Status status = catalog_->GetNumCatalogResetStarts(&current_catalog_resets);

  if (status.ok()) {
    min_catalog_resets_to_serve_.Store(current_catalog_resets + 1);
    LOG(INFO) << "Marking pending metadata reset. Min number of catalog resets to serve: "
              << min_catalog_resets_to_serve_.Load();
  } else {
    /// If somehow we failed to get the number, sets a conservative value.
    min_catalog_resets_to_serve_.Add(1);
    LOG(ERROR) << "Failed to get current catalog version: " << status.GetDetail()
               << "Some requests might run on stale metadata.";
  }
  // Sets this after we updated min_catalog_resets_to_serve_ since the consumers check
  // this before read/write on num of catalog resets. The consumers are
  //  - Requests in WaitPendingMetadataResetStarts(). Read this and num of catalog resets
  //    in JVM.
  //  - TriggerResetMetadata thread. Reads this and updates num of catalog resets in JVM.
  triggered_pending_reset_.Store(false);
}

[[noreturn]] void CatalogServer::TriggerResetMetadata() {
  while (true) {