Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: clippy cleanup

pull/24376/head
Joe-Blount 2023-02-17 15:30:13 -06:00
parent 3997de6a52
commit b3927c89a7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
influxdb_iox/src/commands/run/compactor2.rs
View File

@ -109,11 +109,11 @@ pub async fn command(config: Config) -> Result<(), Error> {
let num_threads = config let num_threads = config
.compactor_config .compactor_config
.query_exec_thread_count .query_exec_thread_count
.unwrap_or_else(|| num_cpus::get() - (1 as usize)); .unwrap_or_else(|| num_cpus::get() - 1_usize);
info!(%num_threads, "using specified number of threads"); info!(%num_threads, "using specified number of threads");
let exec = Arc::new(Executor::new_with_config(ExecutorConfig { let exec = Arc::new(Executor::new_with_config(ExecutorConfig {
num_threads: num_threads, num_threads,
target_query_partitions: num_threads, target_query_partitions: num_threads,
object_stores: [&parquet_store_real, &parquet_store_scratchpad] object_stores: [&parquet_store_real, &parquet_store_scratchpad]
.into_iter() .into_iter()