From 1dd2dc06899e47c40fa8b47d466d2baca902860e Mon Sep 17 00:00:00 2001
From: newborn22 <953950914@qq.com>
Date: Thu, 5 Dec 2024 18:25:18 +0800
Subject: [PATCH] fix: source_host_to_target

---
 endtoend/branch/branch_test.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/endtoend/branch/branch_test.go b/endtoend/branch/branch_test.go
index 5d605b31fe..862f304855 100644
--- a/endtoend/branch/branch_test.go
+++ b/endtoend/branch/branch_test.go
@@ -303,7 +303,7 @@ func TestBranchBasicWithFailPoint(t *testing.T) {
 	defer targetClean()
 
 	// create branch
-	createCMD := getBranchCreateCMD(sourceCluster.MysqlHost, sourceCluster.MysqlPort, "root", "passwd", "*", "information_schema,mysql,performance_schema,sys")
+	createCMD := getBranchCreateCMD(sourceHostToTarget, sourceCluster.MysqlPort, "root", "passwd", "*", "information_schema,mysql,performance_schema,sys")
 	framework.EnableFailPoint(t, targetCluster.WescaleDb, "vitess.io/vitess/go/vt/vtgate/branch/BranchFetchSnapshotError", "return(true)")
 	framework.ExecWithErrorContains(t, targetCluster.WescaleDb, "failpoint", createCMD)
 	expectBranchStatus(t, "my_branch", "init")