processor(ticdc): do not ignore ErrRedoWriterStopped (pingcap#9451)

close pingcap#9378
3AceShowHand · Aug 29, 2023 · 2af966e · 2af966e
1 parent a2aee0c
commit 2af966e
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/cdc/processor/processor.go b/cdc/processor/processor.go
@@ -424,7 +424,6 @@ func newProcessor(
 var processorIgnorableError = []*errors.Error{
 	cerror.ErrAdminStopProcessor,
 	cerror.ErrReactorFinished,
-	cerror.ErrRedoWriterStopped,
 }
 
 // isProcessorIgnorableError returns true if the error means the processor exits

diff --git a/cdc/processor/processor_test.go b/cdc/processor/processor_test.go
@@ -632,7 +632,7 @@ func TestIgnorableError(t *testing.T) {
 		{nil, true},
 		{cerror.ErrAdminStopProcessor.GenWithStackByArgs(), true},
 		{cerror.ErrReactorFinished.GenWithStackByArgs(), true},
-		{cerror.ErrRedoWriterStopped.GenWithStackByArgs(), true},
+		{cerror.ErrRedoWriterStopped.GenWithStackByArgs(), false},
 		{errors.Trace(context.Canceled), true},
 		{cerror.ErrProcessorTableNotFound.GenWithStackByArgs(), false},
 		{errors.New("test error"), false},