diff options
author | Tor Egge <Tor.Egge@online.no> | 2021-11-12 02:17:21 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2021-11-12 02:17:21 +0100 |
commit | 9d462a800f31115c4dc43e56a2dba8809f22a187 (patch) | |
tree | 27c38ad4ff7bd7ac165acf869613e544eaa5d48b /searchcore | |
parent | 40745cf24820bb0b0b0d28259bb5115ed5b068eb (diff) |
Prepare for reduced commit rate for document meta store.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/documentmetastore/documentmetastoreflushtarget.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/documentmetastore/documentmetastoreflushtarget.cpp b/searchcore/src/vespa/searchcore/proton/documentmetastore/documentmetastoreflushtarget.cpp index 6e18575a90a..9164797b86f 100644 --- a/searchcore/src/vespa/searchcore/proton/documentmetastore/documentmetastoreflushtarget.cpp +++ b/searchcore/src/vespa/searchcore/proton/documentmetastore/documentmetastoreflushtarget.cpp @@ -56,8 +56,9 @@ Flusher(DocumentMetaStoreFlushTarget &dmsft, _syncToken(syncToken), _flushDir("") { - DocumentMetaStore &dms = *_dmsft._dms; // Called by document db executor + DocumentMetaStore &dms = *_dmsft._dms; + dms.commit(CommitParam(syncToken)); _flushDir = writer.getSnapshotDir(syncToken); vespalib::string newBaseFileName(_flushDir + "/" + dms.getName()); _saver = dms.initSave(newBaseFileName); |