diff options
| author | nivekuil <mail@nivekuil.com> | 2021-07-16 04:29:46 -0700 |
|---|---|---|
| committer | nivekuil <mail@nivekuil.com> | 2021-07-16 04:29:46 -0700 |
| commit | 2faf96f00261ba34ce5f56cbb91c0adc4b369edf (patch) | |
| tree | 88fa35e53889cf6ae8116efa952436a274ea0b6a | |
| parent | 4be5b4ff5cde0d5bf3fbb4b3e9e9d8f1cf4ec4c8 (diff) | |
| download | seaweedfs-2faf96f00261ba34ce5f56cbb91c0adc4b369edf.tar.xz seaweedfs-2faf96f00261ba34ce5f56cbb91c0adc4b369edf.zip | |
cassandra: Use LocalOne instead of One consistency
| -rw-r--r-- | weed/filer/cassandra/cassandra_store.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/cassandra/cassandra_store.go b/weed/filer/cassandra/cassandra_store.go index f4856657e..d917da518 100644 --- a/weed/filer/cassandra/cassandra_store.go +++ b/weed/filer/cassandra/cassandra_store.go @@ -124,7 +124,7 @@ func (store *CassandraStore) FindEntry(ctx context.Context, fullpath util.FullPa var data []byte if err := store.session.Query( "SELECT meta FROM filemeta WHERE directory=? AND name=?", - dir, name).Consistency(gocql.One).Scan(&data); err != nil { + dir, name).Consistency(gocql.LocalOne).Scan(&data); err != nil { if err != gocql.ErrNotFound { return nil, filer_pb.ErrNotFound } |