From 809aa028ec7be5c6f19945d81d3b3456780b2bc2 Mon Sep 17 00:00:00 2001 From: eshujiushiwo <378013446@qq.com> Date: Mon, 28 Nov 2016 15:01:04 +0800 Subject: [PATCH] fix the connection of cassandra fix the connection of cassandra ,let filer can connect to multi cassandra nodes which are in the one cluster --- weed/filer/cassandra_store/cassandra_store.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/weed/filer/cassandra_store/cassandra_store.go b/weed/filer/cassandra_store/cassandra_store.go index 3005fead9..0431872fa 100644 --- a/weed/filer/cassandra_store/cassandra_store.go +++ b/weed/filer/cassandra_store/cassandra_store.go @@ -2,7 +2,7 @@ package cassandra_store import ( "fmt" - + "strings" "github.com/chrislusf/seaweedfs/weed/filer" "github.com/chrislusf/seaweedfs/weed/glog" @@ -34,11 +34,8 @@ func NewCassandraStore(keyspace string, hosts ...string) (c *CassandraStore, err c = &CassandraStore{} s := strings.Split(hosts, ",") if len(s) == 1 { - fmt.Println("000") c.cluster = gocql.NewCluster(hosts...) } else if len(s) > 1 { - fmt.Println("111",s[0]) - fmt.Println("222",s[1]) c.cluster = gocql.NewCluster(s[0], s[1]) } c.cluster.Keyspace = keyspace