diff options
| -rw-r--r-- | weed/filer2/cassandra/cassandra_store.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/filer2/cassandra/cassandra_store.go b/weed/filer2/cassandra/cassandra_store.go index e8f51dd04..2c1f03182 100644 --- a/weed/filer2/cassandra/cassandra_store.go +++ b/weed/filer2/cassandra/cassandra_store.go @@ -48,8 +48,8 @@ func (store *CassandraStore) InsertEntry(entry *filer2.Entry) (err error) { } if err := store.session.Query( - "INSERT INTO filemeta (directory,name,meta) VALUES(?,?,?)", - dir, name, meta).Exec(); err != nil { + "INSERT INTO filemeta (directory,name,meta) VALUES(?,?,?) USING TTL ? ", + dir, name, meta, entry.TtlSec).Exec(); err != nil { return fmt.Errorf("insert %s: %s", entry.FullPath, err) } |