handle Unexpected transaction rollback

pkg/datasource/sql/undo/base/undo.go

@@ -23,7 +23,6 @@ import (
 	"database/sql/driver"
 	"encoding/json"
 	"fmt"
-
 	"strconv"
 	"strings"
 
@@ -36,6 +35,7 @@ import (
 	"seata.apache.org/seata-go/pkg/datasource/sql/undo/factor"
 	"seata.apache.org/seata-go/pkg/datasource/sql/undo/parser"
 	"seata.apache.org/seata-go/pkg/util/collection"
+	serr "seata.apache.org/seata-go/pkg/util/errors"
 	"seata.apache.org/seata-go/pkg/util/log"
 )
 
@@ -354,6 +354,10 @@ func (m *BaseUndoLogManager) Undo(ctx context.Context, dbType types.DBType, xid
 
 			if err = undoExecutor.ExecuteOn(ctx, dbType, conn); err != nil {
 				log.Errorf("execute on fail, err: %v", err)
+				if undoErr, ok := err.(*serr.SeataError); ok && undoErr.Code == serr.SQLUndoDirtyError {
+					return serr.New(serr.TransactionErrorCodeBranchRollbackFailedUnretriable, fmt.Sprintf(
+						"Branch session rollback failed because of dirty undo log, please delete the relevant undolog after manually calibrating the data. xid = %s branchId = %d: %v", xid, branchID, undoErr), nil)
+				}
 				return err
 			}
 		}
@@ -375,6 +379,7 @@ func (m *BaseUndoLogManager) Undo(ctx context.Context, dbType types.DBType, xid
 
 	if err = tx.Commit(); err != nil {
 		log.Errorf("[Undo] execute on fail, err: %v", err)
+
 		return nil
 	}
 	return nil

pkg/datasource/sql/undo/executor/executor.go

@@ -29,6 +29,7 @@ import (
 	"seata.apache.org/seata-go/pkg/datasource/sql/datasource"
 	"seata.apache.org/seata-go/pkg/datasource/sql/types"
 	"seata.apache.org/seata-go/pkg/datasource/sql/undo"
+	serr "seata.apache.org/seata-go/pkg/util/errors"
 	"seata.apache.org/seata-go/pkg/util/log"
 )
 
@@ -98,7 +99,7 @@ func (b *BaseExecutor) dataValidationAndGoOn(ctx context.Context, conn *sql.Conn
 			newRowJson, _ := json.Marshal(currentImage.Rows)
 			log.Infof("check dirty data failed, old and new data are not equal, "+
 				"tableName:[%s], oldRows:[%s],newRows:[%s].", afterImage.TableName, oldRowJson, newRowJson)
-			return false, fmt.Errorf("Has dirty records when undo.")
+			return false, serr.New(serr.SQLUndoDirtyError, "has dirty records when undo", nil)
 		}
 	}
 	return true, nil

pkg/util/errors/code.go

@@ -100,4 +100,6 @@ const (
 
 	// FencePhaseError have fence phase but is not illegal value
 	FencePhaseError
+
+	SQLUndoDirtyError
 )

pkg/util/errors/error_code_test.go

@@ -51,4 +51,5 @@ func TestTransactionErrorCode(t *testing.T) {
 	assert.Equal(t, int(PrepareFenceError), 24)
 	assert.Equal(t, int(FenceBusinessError), 25)
 	assert.Equal(t, int(FencePhaseError), 26)
+	assert.Equal(t, int(SQLUndoDirtyError), 27)
 }