diff --git a/src/table/src/table/numbers.rs b/src/table/src/table/numbers.rs index d57e10cc29..90b31cc52c 100644 --- a/src/table/src/table/numbers.rs +++ b/src/table/src/table/numbers.rs @@ -26,6 +26,7 @@ use datatypes::data_type::ConcreteDataType; use datatypes::schema::{ColumnSchema, SchemaBuilder, SchemaRef}; use futures::task::{Context, Poll}; use futures::Stream; +use store_api::storage::RegionNumber; use crate::error::Result; use crate::metadata::{TableId, TableInfoBuilder, TableInfoRef, TableMetaBuilder, TableType}; @@ -110,6 +111,10 @@ impl Table for NumbersTable { }); Ok(Arc::new(SimpleTableScan::new(stream))) } + + async fn flush(&self, _region_number: Option, _wait: Option) -> Result<()> { + Ok(()) + } } // Limited numbers stream