diff --git a/test/e2e/e2e_test.go b/test/e2e/e2e_test.go
index 0ca67d1..d9f64ac 100644
--- a/test/e2e/e2e_test.go
+++ b/test/e2e/e2e_test.go
@@ -42,14 +42,12 @@ func TestE2ETestSuite(t *testing.T) {
 }
 
 func (s *e2eTestSuite) SetupSuite() {
-	config := &client.Config{
-		Host:     "iotdb",
-		Port:     "6667",
+	clusterConfig := client.ClusterConfig{
+		NodeUrls: strings.Split("0.0.0.0:6668,0.0.0.0:6667,0.0.0.0:6669", ","),
 		UserName: "root",
 		Password: "root",
 	}
-
-	s.session = client.NewSession(config)
+	s.session = client.NewClusterSession(&clusterConfig)
 	err := s.session.Open(false, 0)
 	s.Require().NoError(err)
 }
@@ -75,20 +73,6 @@ func (s *e2eTestSuite) checkError(status *common.TSStatus, err error) {
 	}
 }
 
-func (s *e2eTestSuite) Test_ClusterSessionInit() {
-	config := &client.ClusterConfig{
-		NodeUrls: strings.Split("iotdb:6668,iotdb:6667,iotdb:6669", ","),
-		UserName: "root",
-		Password: "root",
-	}
-	var session client.Session
-	session = client.NewClusterSession(config)
-	err := session.OpenCluster(false)
-	s.Require().NoError(err)
-	_, err = session.Close()
-	s.Require().NoError(err)
-}
-
 func (s *e2eTestSuite) Test_CreateTimeseries() {
 	var (
 		path       = "root.tsg1.dev1.status"