From 68fdd7058033d421cf7f2cc76a695e720d600f9b Mon Sep 17 00:00:00 2001
From: Yicheng Qin <qycqycqycqycqyc@gmail.com>
Date: Thu, 15 Jan 2015 10:42:57 -0800
Subject: [PATCH] integration: fix TestForceNewCluster

---
 integration/cluster_test.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/integration/cluster_test.go b/integration/cluster_test.go
index 777b4524b..cd707f88e 100644
--- a/integration/cluster_test.go
+++ b/integration/cluster_test.go
@@ -159,6 +159,9 @@ func TestForceNewCluster(t *testing.T) {
 	}
 	defer c.Members[0].Terminate(t)
 
+	// use new http client to init new connection
+	cc = mustNewHTTPClient(t, []string{c.Members[0].URL()})
+	kapi = client.NewKeysAPI(cc)
 	// ensure force restart keep the old data, and new cluster can make progress
 	ctx, cancel = context.WithTimeout(context.Background(), requestTimeout)
 	if _, err := kapi.Watch("/foo", resp.Node.ModifiedIndex).Next(ctx); err != nil {