cluster: deduplicate the check result (#1737)

pkg/cluster/manager/check.go

@@ -478,6 +478,8 @@ func checkSystemInfo(
 		applyFixTasks = append(applyFixTasks, tf.BuildAsStep(fmt.Sprintf("  - Applying changes on %s", host)))
 	}
 
+	checkResults = deduplicateCheckResult(checkResults)
+
 	if gOpt.DisplayMode == "json" {
 		checkResultStruct := make([]HostCheckResult, 0)
 
@@ -689,3 +691,38 @@ func checkConflict(m *Manager, clusterName string, topo spec.Topology) error {
 	err = spec.CheckClusterDirConflict(clusterList, clusterName, topo)
 	return err
 }
+
+// deduplicateCheckResult deduplicate check results
+func deduplicateCheckResult(checkResults []HostCheckResult) (uniqueResults []HostCheckResult) {
+	// node: {name|status: set(msg)}
+	tmpResultMap := map[string]map[string]set.StringSet{}
+
+	// deduplicate
+	for _, result := range checkResults {
+		if tmpResultMap[result.Node] == nil {
+			tmpResultMap[result.Node] = make(map[string]set.StringSet)
+		}
+		// insert msg into set
+		msgKey := fmt.Sprintf("%s|%s", result.Name, result.Status)
+		if tmpResultMap[result.Node][msgKey] == nil {
+			tmpResultMap[result.Node][msgKey] = set.NewStringSet()
+		}
+		tmpResultMap[result.Node][msgKey].Insert(result.Message)
+	}
+
+	for node, msgMap := range tmpResultMap {
+		for checkInfo, msgSet := range msgMap {
+			nameAndstatus := strings.Split(checkInfo, "|")
+			for _, msg := range msgSet.Slice() {
+				uniqueResults = append(uniqueResults,
+					HostCheckResult{
+						Node:    node,
+						Name:    nameAndstatus[0],
+						Status:  nameAndstatus[1],
+						Message: msg,
+					})
+			}
+		}
+	}
+	return
+}

pkg/cluster/manager/manager_test.go

@@ -86,3 +86,24 @@ pd_servers:
 	err = validateNewTopo(&topo)
 	assert.NotNil(err)
 }
+
+func TestDeduplicateCheckResult(t *testing.T) {
+	checkResults := []HostCheckResult{}
+
+	for i := 0; i <= 10; i++ {
+		checkResults = append(checkResults,
+			HostCheckResult{
+				Node:    "127.0.0.1",
+				Status:  "Warn",
+				Name:    "disk",
+				Message: "mount point /home does not have 'noatime' option set",
+			},
+		)
+	}
+
+	checkResults = deduplicateCheckResult(checkResults)
+
+	if len(checkResults) != 1 {
+		t.Errorf("Deduplicate Check Result Failed")
+	}
+}