fix typo

Author: ffffwh

api/handler/v2/job.go

@@ -1404,7 +1404,7 @@ func buildMysqlToKafkaJobDetailResp(nomadJob nomadApi.Job, nomadAllocations []no
 			case common.TaskTypeSrc:
 				srcTaskDetail = buildSrcTaskDetail(t.Name, internalTaskConfig, taskGroupToNomadAlloc[*tg.Name])
 				if nil == internalTaskConfig.KafkaConfig {
-					return models.KafkaDestTaskDetail{}, models.SrcTaskDetail{}, fmt.Errorf("can not find kafka task config from nomad")
+					return models.KafkaDestTaskDetail{}, models.SrcTaskDetail{}, fmt.Errorf("cannot find kafka task config from nomad")
 				}
 				destTaskDetail = buildKafkaDestTaskDetail(t.Name, *internalTaskConfig.KafkaConfig, taskGroupToNomadAlloc[*tg.Name])
 				break
@@ -1492,7 +1492,7 @@ func PauseJobV2(c echo.Context, filterJobType DtleJobType) error {
 	}
 
 	if len(nomadAllocs) == 0 {
-		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("can not find allocations of the job[%v]", reqParam.JobId)))
+		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("cannot find allocations of the job[%v]", reqParam.JobId)))
 	}
 
 	storeManager, err := common.NewStoreManager([]string{handler.ConsulAddr}, logger)
@@ -1598,7 +1598,7 @@ func ResumeJobV2(c echo.Context, filterJobType DtleJobType) error {
 	}
 
 	if len(nomadAllocs) == 0 {
-		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("job_id=%v; can not find allocations of the job", reqParam.JobId)))
+		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("job_id=%v; cannot find allocations of the job", reqParam.JobId)))
 	}
 
 	// update metadata first
@@ -1847,7 +1847,7 @@ func ReverseStartJobV2(c echo.Context, filterJobType DtleJobType) error {
 	}
 
 	if len(nomadAllocs) == 0 {
-		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("can not find allocations of the job[%v]", reqParam.JobId)))
+		return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("cannot find allocations of the job[%v]", reqParam.JobId)))
 	}
 
 	storeManager, err := common.NewStoreManager([]string{handler.ConsulAddr}, logger)

api/handler/v2/monitor.go

@@ -50,7 +50,7 @@ func GetTaskProgressV2(c echo.Context) error {
 			break
 		}
 		if "" == nodeId {
-			return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("can not find out which node the allocation is running on")))
+			return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("cannot find out which node the allocation is running on")))
 		}
 		url = handler.BuildUrl(fmt.Sprintf("/v1/node/%v", nodeId))
 		logger.Info("invoke nomad api begin", "url", url)
@@ -108,7 +108,7 @@ func GetTaskProgressV2(c echo.Context) error {
 		if nil != err {
 			return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("get task stats failed: %v. allocation_id=%v task_name=%v", err, reqParam.AllocationId, reqParam.TaskName)))
 		} else if !ok {
-			return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("can not find the task. allocation_id=%v task_name=%v", reqParam.AllocationId, reqParam.TaskName)))
+			return c.JSON(http.StatusInternalServerError, models.BuildBaseResp(fmt.Errorf("cannot find the task. allocation_id=%v task_name=%v", reqParam.AllocationId, reqParam.TaskName)))
 		}
 
 		// build response struct
@@ -176,15 +176,15 @@ func GetTaskProgressV2(c echo.Context) error {
 func getApiAddrFromAgentConfig(agentConfig map[string]interface{}) (ip, port string, err error) {
 	plugins, ok := agentConfig["Plugins"].([]interface{})
 	if !ok {
-		return "", "", fmt.Errorf("can not find plugin config")
+		return "", "", fmt.Errorf("cannot find plugin config")
 	}
 
 	for _, p := range plugins {
 		plugin := p.(map[string]interface{})
 		if plugin["Name"] == g.PluginName {
 			driverConfig, ok := plugin["Config"].(map[string]interface{})
 			if !ok {
-				return "", "", fmt.Errorf("can not find driver config within dtle plugin config")
+				return "", "", fmt.Errorf("cannot find driver config within dtle plugin config")
 			}
 			addr := driverConfig["api_addr"].(string)
 			if ip, port, err = net.SplitHostPort(addr); nil != err {
@@ -196,5 +196,5 @@ func getApiAddrFromAgentConfig(agentConfig map[string]interface{}) (ip, port str
 		}
 	}
 
-	return "", "", fmt.Errorf("can not find dtle config")
+	return "", "", fmt.Errorf("cannot find dtle config")
 }

driver/mysql/applier_incr.go

@@ -511,7 +511,7 @@ func (a *ApplierIncr) prepareIfNilAndExecute(item *dmlExecItem, workerIdx int) (
 	}
 
 	if err != nil {
-		a.logger.Error("error at exec", "gno", item.gno, "err", err)
+		a.logger.Error("error at exec", "gno", item.gno, "err", err, "worker", workerIdx)
 		return err
 	}
 

driver/mysql/base/utils.go

@@ -443,7 +443,7 @@ func GetTableColumnsSqle(sqleContext *sqle.Context, schema string,
 	table string) (r *common.ColumnList, fkParents []*ast.TableName, err error) {
 	tableInfo, exists := sqleContext.GetTable(schema, table)
 	if !exists {
-		return nil, nil, fmt.Errorf("table does not exists in sqle context. table: %v.%v", schema, table)
+		return nil, nil, fmt.Errorf("table does not exist in sqle context. table: %v.%v", schema, table)
 	}
 
 	cStmt := tableInfo.MergedTable