|
@@ -41,7 +41,7 @@ func initDFS(keyspace string) error {
|
|
|
cassandraOption := cassandra.Option{Keyspace: keyspace, DisableInitialHostLookup: os.Getenv("VERSION") == "dev"}
|
|
|
ccli, err := cassandra.NewClientByOption(cassandraOption)
|
|
|
if err != nil {
|
|
|
- return fmt.Errorf("cassandra.GetClient Error: %v", err)
|
|
|
+ return fmt.Errorf("cassandra.NewClient Error: %v", err)
|
|
|
}
|
|
|
ecli, err := etcd.Get()
|
|
|
if err != nil {
|