dm/pkg/retry: modify ReplicationErrMsgs and add relevant unit test (#…

…3472)
pingcap · Nov 16, 2021 · 8311703 · 8311703
1 parent 3c35455
commit 8311703
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/dm/dm/worker/task_checker_test.go b/dm/dm/worker/task_checker_test.go
@@ -306,6 +306,7 @@ func (s *testTaskCheckerSuite) TestIsResumableError(c *check.C) {
 		{nil, true},
 		{errors.New("unknown error"), true},
 		{terror.ErrNotSet.Delegate(&tmysql.SQLError{Code: 1236, Message: "Could not find first log file name in binary log index file", State: tmysql.DefaultMySQLState}), false},
+		{terror.ErrNotSet.Delegate(&tmysql.SQLError{Code: 1236, Message: "The slave is connecting using CHANGE MASTER TO MASTER_AUTO_POSITION = 1, but the master has purged binary logs containing GTIDs that the slave requires", State: tmysql.DefaultMySQLState}), false},
 	}
 
 	for _, tc := range testCases {

diff --git a/dm/pkg/retry/errors.go b/dm/pkg/retry/errors.go
@@ -52,6 +52,7 @@ var (
 	// ReplicationErrMsgs list the error message of un-recoverable replication error.
 	ReplicationErrMsgs = []string{
 		"Could not find first log file name in binary log index file",
+		"The slave is connecting using CHANGE MASTER TO MASTER_AUTO_POSITION = 1, but the master has purged binary logs containing GTIDs that the slave requires",
 	}
 
 	// ParseRelayLogErrMsgs list the error messages of some un-recoverable relay log parsing error, which is used in task auto recovery.