Skip to content

Commit

Permalink
fix simulation test config
Browse files Browse the repository at this point in the history
  • Loading branch information
zwang28 committed Mar 20, 2023
1 parent d64cc22 commit 1027737
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 3 deletions.
1 change: 1 addition & 0 deletions src/meta/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -251,6 +251,7 @@ pub fn start(opts: MetaNodeOpts) -> Pin<Box<dyn Future<Output = ()> + Send>> {
periodic_ttl_reclaim_compaction_interval_sec: config
.meta
.periodic_ttl_reclaim_compaction_interval_sec,
state_store: config.system.state_store.clone(),
},
config.system.into_init_system_params(),
)
Expand Down
3 changes: 3 additions & 0 deletions src/meta/src/manager/env.rs
Original file line number Diff line number Diff line change
Expand Up @@ -109,6 +109,8 @@ pub struct MetaOpts {

/// Schedule ttl_reclaim_compaction for all compaction groups with this interval.
pub periodic_ttl_reclaim_compaction_interval_sec: u64,

pub state_store: String,
}

impl MetaOpts {
Expand All @@ -133,6 +135,7 @@ impl MetaOpts {
connector_rpc_endpoint: None,
periodic_space_reclaim_compaction_interval_sec: 60,
periodic_ttl_reclaim_compaction_interval_sec: 60,
state_store: "hummock+memory".to_string(),
}
}
}
Expand Down
4 changes: 2 additions & 2 deletions src/object_store/src/object/s3.rs
Original file line number Diff line number Diff line change
Expand Up @@ -486,8 +486,8 @@ impl ObjectStore for S3ObjectStore {
key: obj.key().expect("key required").to_owned(),
last_modified: obj
.last_modified()
.expect("last_modified required")
.as_secs_f64(),
.map(|l|l.as_secs_f64())
.unwrap_or(0f64),
total_size: obj.size() as usize,
})
.collect_vec(),
Expand Down
3 changes: 2 additions & 1 deletion src/tests/simulation/src/risingwave.toml
Original file line number Diff line number Diff line change
Expand Up @@ -4,4 +4,5 @@

[system]
barrier_interval_ms = 250
checkpoint_frequency = 4
checkpoint_frequency = 4
state_store = "hummock+minio://hummockadmin:hummockadmin@192.168.12.1:9301/hummock001"

0 comments on commit 1027737

Please sign in to comment.