diff --git a/src/query/service/src/interpreters/interpreter_table_create.rs b/src/query/service/src/interpreters/interpreter_table_create.rs index dc518ea338eca..acb763f19837f 100644 --- a/src/query/service/src/interpreters/interpreter_table_create.rs +++ b/src/query/service/src/interpreters/interpreter_table_create.rs @@ -18,7 +18,6 @@ use std::sync::Arc; use chrono::Utc; use databend_common_ast::ast::Engine; use databend_common_base::runtime::GlobalIORuntime; -use databend_common_config::GlobalConfig; use databend_common_exception::ErrorCode; use databend_common_exception::Result; use databend_common_expression::is_internal_column; @@ -44,7 +43,6 @@ use databend_common_pipeline::core::always_callback; use databend_common_pipeline::core::ExecutionInfo; use databend_common_sql::plans::CreateTablePlan; use databend_common_sql::DefaultExprBinder; -use databend_common_storages_fuse::io::MetaReaders; use databend_common_storages_fuse::FuseSegmentFormat; use databend_common_storages_fuse::FuseStorageFormat; use databend_common_storages_fuse::FUSE_OPT_KEY_ENABLE_AUTO_ANALYZE; @@ -52,13 +50,9 @@ use databend_common_storages_fuse::FUSE_OPT_KEY_ENABLE_AUTO_VACUUM; use databend_common_users::RoleCacheManager; use databend_common_users::UserApiProvider; use databend_enterprise_attach_table::get_attach_table_handler; -use databend_storages_common_cache::LoadParams; -use databend_storages_common_table_meta::meta::TableSnapshot; -use databend_storages_common_table_meta::meta::Versioned; use databend_storages_common_table_meta::table::OPT_KEY_COMMENT; use databend_storages_common_table_meta::table::OPT_KEY_ENABLE_COPY_DEDUP_FULL_PATH; use databend_storages_common_table_meta::table::OPT_KEY_SEGMENT_FORMAT; -use databend_storages_common_table_meta::table::OPT_KEY_SNAPSHOT_LOCATION; use databend_storages_common_table_meta::table::OPT_KEY_STORAGE_FORMAT; use databend_storages_common_table_meta::table::OPT_KEY_STORAGE_PREFIX; use databend_storages_common_table_meta::table::OPT_KEY_TEMP_PREFIX; @@ -322,37 +316,7 @@ impl CreateTableInterpreter { #[async_backtrace::framed] async fn create_table(&self) -> Result { let catalog = self.ctx.get_catalog(self.plan.catalog.as_str()).await?; - let mut stat = None; - if !GlobalConfig::instance().query.management_mode { - if let Some(snapshot_loc) = self.plan.options.get(OPT_KEY_SNAPSHOT_LOCATION) { - // using application level data operator is a temp workaround - // please see discussions https://github.com/datafuselabs/databend/pull/10424 - let operator = self.ctx.get_application_level_data_operator()?.operator(); - let reader = MetaReaders::table_snapshot_reader(operator); - - let params = LoadParams { - location: snapshot_loc.clone(), - len_hint: None, - ver: TableSnapshot::VERSION, - put_cache: true, - }; - - let snapshot = reader.read(¶ms).await?; - stat = Some(TableStatistics { - number_of_rows: snapshot.summary.row_count, - data_bytes: snapshot.summary.uncompressed_byte_size, - compressed_data_bytes: snapshot.summary.compressed_byte_size, - index_data_bytes: snapshot.summary.index_size, - bloom_index_size: snapshot.summary.bloom_index_size, - ngram_index_size: snapshot.summary.ngram_index_size, - inverted_index_size: snapshot.summary.inverted_index_size, - vector_index_size: snapshot.summary.vector_index_size, - virtual_column_size: snapshot.summary.virtual_column_size, - number_of_segments: Some(snapshot.segments.len() as u64), - number_of_blocks: Some(snapshot.summary.block_count), - }); - } - } + let stat = None; let req = if let Some(storage_prefix) = self.plan.options.get(OPT_KEY_STORAGE_PREFIX) { self.build_attach_request(storage_prefix).await } else {