fix compile and clippy.

Author: Rachelint

analytic_engine/src/instance/open.rs

@@ -8,7 +8,7 @@ use std::{
 };
 
 use common_types::schema::IndexInWriterSchema;
-use log::{debug, error, info, trace, warn};
+use log::{debug, error, info, trace};
 use object_store::ObjectStoreRef;
 use snafu::ResultExt;
 use table_engine::engine::OpenTableRequest;
@@ -24,8 +24,8 @@ use crate::{
     instance::{
         self,
         engine::{
-            ApplyMemTable, FlushTable, OpenManifest, OperateByWriteWorker, ReadMetaUpdate, ReadWal,
-            RecoverTableData, Result,
+            ApplyMemTable, FlushTable, OpenManifest, ReadMetaUpdate, ReadWal, RecoverTableData,
+            Result,
         },
         flush_compaction::TableFlushOptions,
         mem_collector::MemUsageCollector,

analytic_engine/src/manifest/details.rs

@@ -209,7 +209,6 @@ impl TableSnapshotProvider for TableSnapshotProviderImpl {
                 table_name: table_data.name.to_string(),
                 schema: table_data.schema(),
                 opts: table_data.table_options().as_ref().clone(),
-                partition_info: table_data.partition_info.clone(),
             };
 
             let version_snapshot = table_data.current_version().snapshot();
@@ -328,20 +327,20 @@ where
     /// Create a latest snapshot of the current logs.
     async fn build(&self) -> Result<Option<Snapshot>> {
         // Get snapshot data from memory.
-        let snapshot_data = self
+        let table_snapshot_opt = self
             .snapshot_data_provider
             .get_table_snapshot(self.space_id, self.table_id)?;
         let snapshot = Snapshot {
             end_seq: self.end_seq,
-            data: snapshot_data,
+            data: table_snapshot_opt,
         };
 
         // Update the current snapshot to the new one.
         self.snapshot_store.store(&snapshot).await?;
         // Delete the expired logs after saving the snapshot.
         // TODO: Actually this operation can be performed background, and the failure of
         // it can be ignored.
-        self.log_store.delete_up_to(dbg!(snapshot.end_seq)).await?;
+        self.log_store.delete_up_to(snapshot.end_seq).await?;
 
         Ok(Some(snapshot))
     }

analytic_engine/src/table/data.rs

@@ -181,10 +181,7 @@ fn compute_mutable_limit(
     write_buffer_size: u32,
     mutable_limit_write_buffer_size_ratio: f32,
 ) -> u32 {
-    assert!(
-        mutable_limit_write_buffer_size_ratio >= 0.0
-            && mutable_limit_write_buffer_size_ratio <= 1.0
-    );
+    assert!((0.0..=1.0).contains(&mutable_limit_write_buffer_size_ratio));
 
     let limit = write_buffer_size as f32 * mutable_limit_write_buffer_size_ratio;
     // This is safe because the limit won't be larger than the write_buffer_size.