Skip to content

Commit 3a9cba4

Browse files
authored
fix(cubestore): RocksStore - specify TTL for WAL to protect logs uploading (#6345)
1 parent e483afb commit 3a9cba4

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

rust/cubestore/cubestore/src/cachestore/cache_rocksstore.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -79,6 +79,10 @@ impl RocksStoreDetails for RocksCacheStoreDetails {
7979
opts.set_compaction_filter_factory(compaction::MetaStoreCacheCompactionFactory::new(
8080
compaction_state,
8181
));
82+
// TODO(ovr): Decrease after additional fix for get_updates_since
83+
opts.set_wal_ttl_seconds(
84+
config.meta_store_snapshot_interval() + config.meta_store_log_upload_interval(),
85+
);
8286
// Disable automatic compaction before migration, will be enabled later in after_migration
8387
opts.set_disable_auto_compactions(true);
8488

rust/cubestore/cubestore/src/metastore/mod.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1152,6 +1152,10 @@ impl RocksStoreDetails for RocksMetaStoreDetails {
11521152
opts.create_if_missing(true);
11531153
opts.set_prefix_extractor(rocksdb::SliceTransform::create_fixed_prefix(13));
11541154
opts.set_merge_operator_associative("meta_store merge", meta_store_merge);
1155+
// TODO(ovr): Decrease after additional fix for get_updates_since
1156+
opts.set_wal_ttl_seconds(
1157+
config.meta_store_snapshot_interval() + config.meta_store_log_upload_interval(),
1158+
);
11551159

11561160
let block_opts = {
11571161
let mut block_opts = BlockBasedOptions::default();

0 commit comments

Comments
 (0)