error_message: more friendly error message

_utils/terror_gen/checker_template.go

@@ -71,7 +71,13 @@ func genErrors() {
 	w := bufio.NewWriter(f)
 	for _, item := range errors {
 		s := strings.SplitN(item.err.Error(), " ", 2)
-		w.WriteString(fmt.Sprintf("%s,%s \"%s\"\n", item.name, s[0], strings.ReplaceAll(s[1], "\n", "\\n")))
+		if len(s) > 1 {
+			// errName,[code:class:scope:level], "Message, RawCause, Workaround"
+			w.WriteString(fmt.Sprintf("%s,%s \"%s\"\n", item.name, s[0], strings.ReplaceAll(s[1], "\n", "\\n")))
+		} else {
+			// errName,[code:class:scope:level]
+			w.WriteString(fmt.Sprintf("%s,%s\n", item.name, s[0]))
+		}
 
 		body := tomlErrorBody{
 			Message:     item.err.Message(),

checker/cmd.go

@@ -70,7 +70,7 @@ func CheckSyncConfig(ctx context.Context, cfgs []*config.SubTaskConfig) error {
 		r := <-pr
 		// we only want first error
 		if len(r.Errors) > 0 {
-			return terror.ErrTaskCheckSyncConfigError.Generate(ErrorMsgHeader, r.Errors[0].Msg, string(r.Detail))
+			return terror.ErrTaskCheckSyncConfigError.Generate(ErrorMsgHeader, r.Errors[0].Message, string(r.Detail))
 		}
 	}
 

dm/config/subtask_test.go

@@ -99,47 +99,47 @@ func (t *testConfig) TestSubTaskAdjustFail(c *C) {
 				cfg.Name = ""
 				return cfg
 			},
-			"\\[.*\\], msg: 'task name should not be empty'.*",
+			"\\[.*\\], Message: task name should not be empty.*",
 		},
 		{
 			func() *SubTaskConfig {
 				cfg := newSubTaskConfig()
 				cfg.SourceID = ""
 				return cfg
 			},
-			"\\[.*\\], msg: 'empty source-id not valid'.*",
+			"\\[.*\\], Message: empty source-id not valid.*",
 		},
 		{
 			func() *SubTaskConfig {
 				cfg := newSubTaskConfig()
 				cfg.SourceID = "source-id-length-more-than-thirty-two"
 				return cfg
 			},
-			"\\[.*\\], msg: 'too long source-id not valid'.*",
+			"\\[.*\\], Message: too long source-id not valid.*",
 		},
 		{
 			func() *SubTaskConfig {
 				cfg := newSubTaskConfig()
 				cfg.ShardMode = "invalid-shard-mode"
 				return cfg
 			},
-			"\\[.*\\], msg: 'shard mode invalid-shard-mode not supported'.*",
+			"\\[.*\\], Message: shard mode invalid-shard-mode not supported.*",
 		},
 		{
 			func() *SubTaskConfig {
 				cfg := newSubTaskConfig()
 				cfg.OnlineDDLScheme = "rtc"
 				return cfg
 			},
-			"\\[.*\\], msg: 'online scheme rtc not supported'.*",
+			"\\[.*\\], Message: online scheme rtc not supported.*",
 		},
 		{
 			func() *SubTaskConfig {
 				cfg := newSubTaskConfig()
 				cfg.Timezone = "my-house"
 				return cfg
 			},
-			"\\[.*\\], msg: 'invalid timezone string: my-house:.*",
+			"\\[.*\\], Message: invalid timezone string: my-house.*",
 		},
 	}
 

dm/ctl/master/query_status_test.go

@@ -76,7 +76,7 @@ func (t *testCtlMaster) TestWrapTaskResult(c *check.C) {
 				Name:  "test",
 				Stage: pb.Stage_Paused,
 				Result: &pb.ProcessResult{
-					Errors: []*pb.ProcessError{{Error: &pb.TError{}}},
+					Errors: []*pb.ProcessError{{}},
 				},
 			}},
 		},
@@ -95,7 +95,7 @@ func (t *testCtlMaster) TestWrapTaskResult(c *check.C) {
 	resp.Sources[0].SourceStatus.RelayStatus = &pb.RelayStatus{
 		Stage: pb.Stage_Paused,
 		Result: &pb.ProcessResult{
-			Errors: []*pb.ProcessError{{Error: &pb.TError{}}},
+			Errors: []*pb.ProcessError{{}},
 		}}
 	expectedResult[0].TaskStatus = stageError + " - Relay status is " + stageError + extraInfo
 	generateAndCheckTaskResult(c, resp, expectedResult)
@@ -132,7 +132,7 @@ func (t *testCtlMaster) TestWrapTaskResult(c *check.C) {
 			Name:  "test2",
 			Stage: pb.Stage_Paused,
 			Result: &pb.ProcessResult{
-				Errors: []*pb.ProcessError{{Error: &pb.TError{}}},
+				Errors: []*pb.ProcessError{{}},
 			},
 		}},
 	})