diff --git a/cpp/arcticdb/util/constants.hpp b/cpp/arcticdb/util/constants.hpp index d10f4984c8..4f9779af81 100644 --- a/cpp/arcticdb/util/constants.hpp +++ b/cpp/arcticdb/util/constants.hpp @@ -19,7 +19,9 @@ constexpr auto string_nan = std::numeric_limits::max() - 1; constexpr auto NaT = std::numeric_limits::min(); -static constexpr decltype(timestamp(0) - timestamp(0)) ONE_SECOND = 1'000'000'000; +static constexpr decltype(timestamp(0) - timestamp(0)) ONE_MILLISECOND = 1'000'000; + +static constexpr decltype(timestamp(0) - timestamp(0)) ONE_SECOND = 1'000 * ONE_MILLISECOND; static constexpr decltype(timestamp(0) - timestamp(0)) ONE_MINUTE = 60 * ONE_SECOND; diff --git a/cpp/arcticdb/version/version_map.hpp b/cpp/arcticdb/version/version_map.hpp index 9b05ca11a4..686f5af6a8 100644 --- a/cpp/arcticdb/version/version_map.hpp +++ b/cpp/arcticdb/version/version_map.hpp @@ -107,7 +107,7 @@ class VersionMapImpl { */ using MapType = std::map>; - static constexpr uint64_t DEFAULT_CLOCK_UNSYNC_TOLERANCE = ONE_SECOND * 2; + static constexpr uint64_t DEFAULT_CLOCK_UNSYNC_TOLERANCE = ONE_MILLISECOND * 200; static constexpr uint64_t DEFAULT_RELOAD_INTERVAL = ONE_SECOND * 2; MapType map_; bool validate_ = false; diff --git a/cpp/arcticdb/version/version_store_api.cpp b/cpp/arcticdb/version/version_store_api.cpp index 8c43ac12f0..8f3c933945 100644 --- a/cpp/arcticdb/version/version_store_api.cpp +++ b/cpp/arcticdb/version/version_store_api.cpp @@ -1125,6 +1125,7 @@ std::vector PythonVersionStore::list_incompletes(const StreamId& st } void PythonVersionStore::clear(const bool continue_on_error) { + version_map()->flush(); if (store()->fast_delete()) { // Most storage backends have a fast deletion method for a db/collection equivalent, eg. drop() for mongo and // lmdb and iterating each key is always going to be suboptimal.