We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 086cec1 commit 3020767Copy full SHA for 3020767
src/mongo/db/storage/wiredtiger/wiredtiger_oplog_manager.cpp
@@ -177,7 +177,10 @@ void WiredTigerOplogManager::_oplogJournalThreadLoop(WiredTigerSessionCache* ses
177
178
const uint64_t newTimestamp = _fetchAllCommittedValue(sessionCache->conn());
179
180
- if (newTimestamp == _oplogReadTimestamp.load()) {
+ // The newTimestamp may actually go backward during secondary batch application,
181
+ // where we commit data file changes separately from oplog changes, so ignore
182
+ // a non-incrementing timestamp.
183
+ if (newTimestamp <= _oplogReadTimestamp.load()) {
184
LOG(2) << "no new oplog entries were made visible: " << newTimestamp;
185
continue;
186
}
0 commit comments