From b022556b79a3bbd740d3f4a805220e86042ab0a0 Mon Sep 17 00:00:00 2001 From: Eugene Tolbakov Date: Sun, 5 Mar 2023 11:37:23 +0000 Subject: [PATCH] fix: apply ttl and write_buffer_size options when a table is created via procedure (#1117) * fix: apply ttl and write_buffer_size options when a table is created via procedure * fix: address code review suggestion * fix: use borrowing of table_options correctly --- src/mito/src/engine/procedure/create.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/src/mito/src/engine/procedure/create.rs b/src/mito/src/engine/procedure/create.rs index 35bce2e3dc..0f3d504bee 100644 --- a/src/mito/src/engine/procedure/create.rs +++ b/src/mito/src/engine/procedure/create.rs @@ -151,15 +151,18 @@ impl CreateMitoTable { &self.data.request.schema_name, self.data.request.id, ); + let table_options = &self.data.request.table_options; + let write_buffer_size = table_options.write_buffer_size.map(|size| size.0 as usize); + let ttl = table_options.ttl; let open_opts = OpenOptions { parent_dir: table_dir.clone(), - write_buffer_size: None, - ttl: None, + write_buffer_size, + ttl, }; let create_opts = CreateOptions { parent_dir: table_dir, - write_buffer_size: None, - ttl: None, + write_buffer_size, + ttl, }; let table_schema =