diff --git a/pkg/apply/processor/create.go b/pkg/apply/processor/create.go
index 8f6b25b1d4d..429e9290520 100644
--- a/pkg/apply/processor/create.go
+++ b/pkg/apply/processor/create.go
@@ -78,7 +78,11 @@ func (c *CreateProcessor) GetPipeLine() ([]func(cluster *v2.Cluster) error, erro
 
 func (c *CreateProcessor) Check(cluster *v2.Cluster) error {
 	logger.Info("Executing pipeline Check in CreateProcessor.")
-	return NewCheckError(checker.RunCheckList([]checker.Interface{checker.NewHostChecker()}, cluster, checker.PhasePre))
+	var ips []string
+	// the order doesn't matter
+	ips = append(ips, cluster.GetMasterIPAndPortList()...)
+	ips = append(ips, cluster.GetNodeIPAndPortList()...)
+	return NewCheckError(checker.RunCheckList([]checker.Interface{checker.NewIPsHostChecker(ips)}, cluster, checker.PhasePre))
 }
 
 func (c *CreateProcessor) PreProcess(cluster *v2.Cluster) error {
diff --git a/pkg/checker/host_checker.go b/pkg/checker/host_checker.go
index 1cc11086765..c8bb45916e7 100644
--- a/pkg/checker/host_checker.go
+++ b/pkg/checker/host_checker.go
@@ -50,10 +50,6 @@ func (a HostChecker) Check(cluster *v2.Cluster, _ string) error {
 	return checkTimeSync(sshClient, ipList)
 }
 
-func NewHostChecker() Interface {
-	return &HostChecker{}
-}
-
 func NewIPsHostChecker(ips []string) Interface {
 	return &HostChecker{IPs: ips}
 }