summaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@online.no>2021-11-12 02:17:21 +0100
committerTor Egge <Tor.Egge@online.no>2021-11-12 02:17:21 +0100
commit9d462a800f31115c4dc43e56a2dba8809f22a187 (patch)
tree27c38ad4ff7bd7ac165acf869613e544eaa5d48b /searchcore
parent40745cf24820bb0b0b0d28259bb5115ed5b068eb (diff)
Prepare for reduced commit rate for document meta store.
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/vespa/searchcore/proton/documentmetastore/documentmetastoreflushtarget.cpp3
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);