Browse Source
Merge pull request #2204 from nivekuil/tokenpolicy
cassandra: use LocalQuorum for all queries
pull/2210/head
Chris Lu
3 years ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with
1 additions and
1 deletions
-
weed/filer/cassandra/cassandra_store.go
|
|
@ -124,7 +124,7 @@ func (store *CassandraStore) FindEntry(ctx context.Context, fullpath util.FullPa |
|
|
var data []byte |
|
|
var data []byte |
|
|
if err := store.session.Query( |
|
|
if err := store.session.Query( |
|
|
"SELECT meta FROM filemeta WHERE directory=? AND name=?", |
|
|
"SELECT meta FROM filemeta WHERE directory=? AND name=?", |
|
|
dir, name).Consistency(gocql.LocalOne).Scan(&data); err != nil { |
|
|
|
|
|
|
|
|
dir, name).Scan(&data); err != nil { |
|
|
if err != gocql.ErrNotFound { |
|
|
if err != gocql.ErrNotFound { |
|
|
return nil, filer_pb.ErrNotFound |
|
|
return nil, filer_pb.ErrNotFound |
|
|
} |
|
|
} |
|
|
|
