v1.0.0 don't support binlog.drainer.config (#775)

Author: weekface

tests/actions.go

@@ -2291,31 +2291,48 @@ func (oa *operatorActions) DeployIncrementalBackup(from *TidbClusterConfig, to *
 	oa.EmitEvent(from, fmt.Sprintf("DeployIncrementalBackup: slave: %s", to.ClusterName))
 	glog.Infof("begin to deploy incremental backup cluster[%s] namespace[%s]", from.ClusterName, from.Namespace)
 
-	sets := map[string]string{
-		"binlog.pump.create": "true",
+	// v1.0.0 don't support `binlog.drainer.config`
+	// https://github.com/pingcap/tidb-operator/pull/693
+	isv1 := from.OperatorTag == "v1.0.0"
+
+	var sets map[string]string
+	if isv1 {
+		sets = map[string]string{
+			"binlog.pump.create":            "true",
+			"binlog.drainer.destDBType":     "mysql",
+			"binlog.drainer.mysql.host":     fmt.Sprintf("%s-tidb.%s", to.ClusterName, to.Namespace),
+			"binlog.drainer.mysql.user":     "root",
+			"binlog.drainer.mysql.password": to.Password,
+			"binlog.drainer.mysql.port":     "4000",
+			"binlog.drainer.ignoreSchemas":  "",
+		}
+	} else {
+		sets = map[string]string{
+			"binlog.pump.create": "true",
+		}
+		from.drainerConfig = []string{
+			"worker-count = 16",
+			"detect-interval = 10",
+			"disable-dispatch = false",
+			`ignore-schemas = ""`,
+			`safe-mode = false`,
+			`txn-batch = 20`,
+			`db-type = "mysql"`,
+			`[syncer.to]`,
+			fmt.Sprintf(`host = "%s-tidb.%s"`, to.ClusterName, to.Namespace),
+			fmt.Sprintf(`user = "%s"`, "root"),
+			fmt.Sprintf(`password = "%s"`, to.Password),
+			fmt.Sprintf(`port = %d`, 4000),
+		}
 	}
+
 	if withDrainer {
 		sets["binlog.drainer.create"] = "true"
 	}
 	if ts != "" {
 		sets["binlog.drainer.initialCommitTs"] = ts
 	}
 
-	from.drainerConfig = []string{
-		"worker-count = 16",
-		"detect-interval = 10",
-		"disable-dispatch = false",
-		`ignore-schemas = ""`,
-		`safe-mode = false`,
-		`txn-batch = 20`,
-		`db-type = "mysql"`,
-		`[syncer.to]`,
-		fmt.Sprintf(`host = "%s-tidb.%s"`, to.ClusterName, to.Namespace),
-		fmt.Sprintf(`user = "%s"`, "root"),
-		fmt.Sprintf(`password = "%s"`, to.Password),
-		fmt.Sprintf(`port = %d`, 4000),
-	}
-
 	cmd, err := oa.getHelmUpgradeClusterCmd(from, sets)
 	if err != nil {
 		return err