mongodb/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SERVER-56896 Log the duplicate key error concisley with arrtributes

Browse Source
This commit is contained in:
Chenhao Qu 2023-10-31 06:31:42 +11:00
parent 92b41dc3f1
commit aaa930aaed
2 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/mongo/db/repl/oplog_applier_utils.cpp
View File

@ -641,6 +641,14 @@ Status OplogApplierUtils::applyOplogBatchCommon(
"error"_attr = causedBy(redact(status)));
return status;
}
} catch (const ExceptionFor<ErrorCodes::DuplicateKey>& e) {
auto info = e.extraInfo<DuplicateKeyErrorInfo>();
LOGV2_FATAL_CONTINUE(5689600,
"Writer worker caught duplicate key exception",
"keyPattern"_attr = redact(info->getKeyPattern()),
"keyValue"_attr = redact(info->getDuplicatedKeyValue()),
"oplogEntry"_attr = redact(op->toBSONForLogging()));
return e.toStatus();
} catch (const DBException& e) {
// SERVER-24927 If we have a NamespaceNotFound exception, then this document will be
// dropped before initial sync or recovery ends anyways and we should ignore it.

7
src/mongo/db/repl/replication_recovery.cpp
View File

@ -509,6 +509,13 @@ boost::optional<Timestamp> ReplicationRecoveryImpl::recoverFromOplog(
opCtx, _consistencyMarkers->getAppliedThrough(opCtx), topOfOplog);
}
return stableTimestamp;
} catch (const ExceptionFor<ErrorCodes::DuplicateKey>& e) {
auto info = e.extraInfo<DuplicateKeyErrorInfo>();
LOGV2_FATAL_CONTINUE(5689601,
"Caught duplicate key exception during replication recovery",
"keyPattern"_attr = redact(info->getKeyPattern()),
"keyValue"_attr = redact(info->getDuplicatedKeyValue()));
std::terminate();
} catch (...) {
LOGV2_FATAL_CONTINUE(
21570, "Caught exception during replication recovery", "error"_attr = exceptionToStatus());