use more safe filter to filter default cf

br/pkg/restore/utils/rewrite_rule.go

@@ -116,11 +116,13 @@ func (r *RewriteRules) SetTimeRangeFilter(cfName string) error {
 	var ignoreBeforeTs uint64
 	switch {
 	case strings.Contains(cfName, DefaultCFName):
-		// for default cf, we need to check if shift start ts is greater than start ts
-		if r.ShiftStartTs > r.StartTs {
-			return errors.Errorf("shift start ts %d is greater than start ts %d", r.ShiftStartTs, r.StartTs)
-		}
 		ignoreBeforeTs = r.ShiftStartTs
+		if ignoreBeforeTs > r.StartTs {
+			// for default cf, shift start ts could less than start ts
+			// this could happen when large kv txn happen after small kv txn.
+			// use the start ts to filter out irrelevant data for default cf is more safe
+			ignoreBeforeTs = r.StartTs
+		}
 	case strings.Contains(cfName, WriteCFName):
 		ignoreBeforeTs = r.StartTs
 	default:

br/pkg/restore/utils/rewrite_rule_test.go

@@ -564,7 +564,7 @@ func TestSetTimeRangeFilter(t *testing.T) {
 				RestoredTs:   200,
 			},
 			cfName:      "default",
-			expectError: true,
+			expectError: false,
 		},
 		{
 			name: "write cf valid shift start ts (greater than start ts)",
@@ -610,7 +610,6 @@ func TestSetTimeRangeFilter(t *testing.T) {
 	for _, tc := range testCases {
 		t.Run(tc.name, func(t *testing.T) {
 			err := tc.rules.SetTimeRangeFilter(tc.cfName)
-
 			if tc.expectError {
 				require.Error(t, err)
 				return
@@ -631,8 +630,11 @@ func TestSetTimeRangeFilter(t *testing.T) {
 				require.Equal(t, tc.rules.RestoredTs, rule.IgnoreAfterTimestamp)
 
 				if strings.Contains(tc.cfName, "default") {
-					require.Equal(t, tc.rules.ShiftStartTs, rule.IgnoreBeforeTimestamp)
-					require.Less(t, tc.rules.ShiftStartTs, tc.rules.StartTs)
+					if tc.rules.ShiftStartTs < tc.rules.StartTs {
+						require.Equal(t, tc.rules.ShiftStartTs, rule.IgnoreBeforeTimestamp)
+					} else {
+						require.Equal(t, tc.rules.StartTs, rule.IgnoreBeforeTimestamp)
+					}
 				} else if strings.Contains(tc.cfName, "write") {
 					require.Equal(t, tc.rules.StartTs, rule.IgnoreBeforeTimestamp)
 				}