fix tests

src/batch/src/executor/insert.rs

@@ -312,6 +312,7 @@ mod tests {
                     ignore_range_tombstone: false,
                     table_id: Default::default(),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await?;

src/batch/src/executor/mod.rs

@@ -229,7 +229,7 @@ impl<'a, C: BatchTaskContext> ExecutorBuilder<'a, C> {
 
 #[cfg(test)]
 mod tests {
-    use risingwave_hummock_sdk::to_commited_batch_query_epoch;
+    use risingwave_hummock_sdk::to_committed_batch_query_epoch;
     use risingwave_pb::batch_plan::PlanNode;
 
     use crate::executor::ExecutorBuilder;
@@ -249,7 +249,7 @@ mod tests {
             &plan_node,
             task_id,
             ComputeNodeContext::for_test(),
-            to_commited_batch_query_epoch(u64::MAX),
+            to_committed_batch_query_epoch(u64::MAX),
         );
         let child_plan = &PlanNode {
             ..Default::default()

src/batch/src/task/task_manager.rs

@@ -215,7 +215,7 @@ mod tests {
     use risingwave_common::config::BatchConfig;
     use risingwave_common::types::DataType;
     use risingwave_expr::expr::make_i32_literal;
-    use risingwave_hummock_sdk::to_commited_batch_query_epoch;
+    use risingwave_hummock_sdk::to_committed_batch_query_epoch;
     use risingwave_pb::batch_plan::exchange_info::DistributionMode;
     use risingwave_pb::batch_plan::plan_node::NodeBody;
     use risingwave_pb::batch_plan::{
@@ -284,13 +284,13 @@ mod tests {
             .fire_task(
                 &task_id,
                 plan.clone(),
-                to_commited_batch_query_epoch(0),
+                to_committed_batch_query_epoch(0),
                 context.clone(),
             )
             .await
             .unwrap();
         let err = manager
-            .fire_task(&task_id, plan, to_commited_batch_query_epoch(0), context)
+            .fire_task(&task_id, plan, to_committed_batch_query_epoch(0), context)
             .await
             .unwrap_err();
         assert!(err
@@ -334,7 +334,7 @@ mod tests {
             .fire_task(
                 &task_id,
                 plan.clone(),
-                to_commited_batch_query_epoch(0),
+                to_committed_batch_query_epoch(0),
                 context.clone(),
             )
             .await

src/compute/tests/integration_tests.rs

@@ -35,7 +35,7 @@ use risingwave_common::test_prelude::DataChunkTestExt;
 use risingwave_common::types::{DataType, IntoOrdered};
 use risingwave_common::util::epoch::EpochPair;
 use risingwave_common::util::sort_util::{OrderPair, OrderType};
-use risingwave_hummock_sdk::to_commited_batch_query_epoch;
+use risingwave_hummock_sdk::to_committed_batch_query_epoch;
 use risingwave_source::table_test_utils::create_table_source_desc_builder;
 use risingwave_source::{TableSourceManager, TableSourceManagerRef};
 use risingwave_storage::memory::MemoryStateStore;
@@ -221,7 +221,7 @@ async fn test_table_materialize() -> StreamResult<()> {
     let scan = Box::new(RowSeqScanExecutor::new(
         table.clone(),
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1024,
         "RowSeqExecutor2".to_string(),
         None,
@@ -283,7 +283,7 @@ async fn test_table_materialize() -> StreamResult<()> {
     let scan = Box::new(RowSeqScanExecutor::new(
         table.clone(),
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1024,
         "RowSeqScanExecutor2".to_string(),
         None,
@@ -355,7 +355,7 @@ async fn test_table_materialize() -> StreamResult<()> {
     let scan = Box::new(RowSeqScanExecutor::new(
         table,
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1024,
         "RowSeqScanExecutor2".to_string(),
         None,
@@ -422,7 +422,7 @@ async fn test_row_seq_scan() -> Result<()> {
     let executor = Box::new(RowSeqScanExecutor::new(
         table,
         vec![ScanRange::full()],
-        to_commited_batch_query_epoch(u64::MAX),
+        to_committed_batch_query_epoch(u64::MAX),
         1,
         "RowSeqScanExecutor2".to_string(),
         None,

src/storage/hummock_sdk/src/lib.rs

@@ -183,7 +183,7 @@ impl From<BatchQueryEpoch> for HummockReadEpoch {
     }
 }
 
-pub fn to_commited_batch_query_epoch(epoch: u64) -> BatchQueryEpoch {
+pub fn to_committed_batch_query_epoch(epoch: u64) -> BatchQueryEpoch {
     BatchQueryEpoch {
         epoch: Some(batch_query_epoch::Epoch::Committed(epoch)),
     }

src/storage/hummock_test/benches/bench_hummock_iter.rs

@@ -100,6 +100,7 @@ fn criterion_benchmark(c: &mut Criterion) {
                         check_bloom_filter: false,
                         retention_seconds: None,
                         table_id: Default::default(),
+                        read_version_from_backup: false,
                     },
                 ))
                 .unwrap();

src/storage/hummock_test/src/compactor_tests.rs

@@ -302,6 +302,7 @@ pub(crate) mod tests {
                     prefix_hint: None,
                     table_id: Default::default(),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await
@@ -320,6 +321,7 @@ pub(crate) mod tests {
                     prefix_hint: None,
                     table_id: Default::default(),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await;
@@ -431,6 +433,7 @@ pub(crate) mod tests {
                     prefix_hint: None,
                     table_id: Default::default(),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await
@@ -783,6 +786,7 @@ pub(crate) mod tests {
                     prefix_hint: None,
                     table_id: TableId::from(existing_table_ids),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await
@@ -955,6 +959,7 @@ pub(crate) mod tests {
                     prefix_hint: None,
                     table_id: TableId::from(existing_table_id),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await
@@ -1128,6 +1133,7 @@ pub(crate) mod tests {
                     prefix_hint: Some(bloom_filter_key),
                     table_id: TableId::from(existing_table_id),
                     retention_seconds: None,
+                    read_version_from_backup: false,
                 },
             )
             .await