Fix checkpoint compare

pingcap · Feb 26, 2021 · f96e2ca · f96e2ca
1 parent 7ed712a
commit f96e2ca
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/checkpoint/checkpoint.go b/pkg/checkpoint/checkpoint.go
@@ -207,11 +207,16 @@ next_set:
 			if cf.eq == nil {
 				continue
 			}
-			if !cf.eq(ma[cf.field], mb[cf.field]) {
+			if !contains(ma, cf.field) || !contains(mb, cf.field) || !cf.eq(ma[cf.field], mb[cf.field]) {
 				continue next_set
 			}
 		}
 		return true
 	}
 	return false
 }
+
+func contains(m map[string]interface{}, f string) bool {
+	_, ok := m[f]
+	return ok
+}