diff --git a/src/mito2/src/config.rs b/src/mito2/src/config.rs index cc25be263bf6..32376aa802ed 100644 --- a/src/mito2/src/config.rs +++ b/src/mito2/src/config.rs @@ -294,6 +294,14 @@ impl InvertedIndexConfig { self.intermediate_path = join_dir(data_home, "index_intermediate"); } + if self.write_buffer_size < MULTIPART_UPLOAD_MINIMUM_SIZE { + self.write_buffer_size = MULTIPART_UPLOAD_MINIMUM_SIZE; + warn!( + "Sanitize index write buffer size to {}", + self.write_buffer_size + ); + } + Ok(()) } }