tikv
/
client-go
mirror of https://github.com/tikv/client-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

logs: downgrade some logs from ERROR to WARN and INFO (#1729) 

ref pingcap/tidb#62704

Signed-off-by: ekexium <eke@fastmail.com>
This commit is contained in:
ekexium 2025-09-19 15:22:20 +08:00 committed by GitHub
parent 6cbd7e4f97
commit f3cd192d09
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
txnkv/transaction/2pc.go
View File

@ -1817,7 +1817,7 @@ func (c *twoPhaseCommitter) execute(ctx context.Context) (err error) {
// RPCs fails. However, if there are multiple errors and some of the errors // RPCs fails. However, if there are multiple errors and some of the errors
// are not RPC failures, we can return the actual error instead of undetermined. // are not RPC failures, we can return the actual error instead of undetermined.
if undeterminedErr := c.getUndeterminedErr(); undeterminedErr != nil { if undeterminedErr := c.getUndeterminedErr(); undeterminedErr != nil {
logutil.Logger(ctx).Error("Async commit/1PC result undetermined", logutil.Logger(ctx).Warn("Async commit/1PC result undetermined",
zap.Error(err), zap.Error(err),
zap.NamedError("rpcErr", undeterminedErr), zap.NamedError("rpcErr", undeterminedErr),
zap.Uint64("txnStartTS", c.startTS)) zap.Uint64("txnStartTS", c.startTS))
@ -2008,7 +2008,7 @@ func (c *twoPhaseCommitter) commitTxn(ctx context.Context, commitDetail *util.Co
} }
if err != nil { if err != nil {
if undeterminedErr := c.getUndeterminedErr(); undeterminedErr != nil { if undeterminedErr := c.getUndeterminedErr(); undeterminedErr != nil {
logutil.Logger(ctx).Error("2PC commit result undetermined", logutil.Logger(ctx).Warn("2PC commit result undetermined",
zap.Error(err), zap.Error(err),
zap.NamedError("rpcErr", undeterminedErr), zap.NamedError("rpcErr", undeterminedErr),
zap.Uint64("txnStartTS", c.startTS)) zap.Uint64("txnStartTS", c.startTS))