diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2021-07-20 15:37:31 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-07-20 15:37:31 -0700 |
| commit | a125c8fbe272818400889bcd8d45819d4570a694 (patch) | |
| tree | ca301a79c61578719b1df0426d77b41aca7178b2 | |
| parent | 54c8bc867376f54ad0bbe9f4f58767767f9cb650 (diff) | |
| parent | b9a67d46c5a1dc6ee18ab0835e6db014b0100c04 (diff) | |
| download | seaweedfs-a125c8fbe272818400889bcd8d45819d4570a694.tar.xz seaweedfs-a125c8fbe272818400889bcd8d45819d4570a694.zip | |
Merge pull request #2204 from nivekuil/tokenpolicy
cassandra: use LocalQuorum for all queries
| -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 d917da518..7affab9ec 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.LocalOne).Scan(&data); err != nil { + dir, name).Scan(&data); err != nil { if err != gocql.ErrNotFound { return nil, filer_pb.ErrNotFound } |