Replace sync_all with forceCommit.
@@ -303,7 +303,9 @@ void
FeedHandler::performEof()
{
assert(_writeService.master().isCurrentThread());
- _writeService.sync_all_executors();
+ vespalib::Gate gate;
+ _activeFeedView->forceCommit(CommitParam(_serialNum), std::make_shared<vespalib::GateCallback>(gate));
+ gate.await();
LOG(debug, "Visiting done for transaction log domain '%s', eof received", _tlsMgr.getDomainName().c_str());
// Replay must be complete
if (_replay_end_serial_num != _serialNum) {
