resolve comment

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Apr 18, 2024 · e87c4e0 · e87c4e0
1 parent 84d7681
commit e87c4e0
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/stream/src/common/log_store_impl/kv_log_store/serde.rs b/src/stream/src/common/log_store_impl/kv_log_store/serde.rs
@@ -43,7 +43,6 @@ use risingwave_storage::row_serde::row_serde_util::{serialize_pk, serialize_pk_w
 use risingwave_storage::row_serde::value_serde::ValueRowSerdeNew;
 use risingwave_storage::store::{StateStoreIterExt, StateStoreReadIter};
 use risingwave_storage::table::{compute_vnode, TableDistribution, SINGLETON_VNODE};
-use risingwave_storage::StateStoreIter;
 use rw_futures_util::select_all;
 
 use crate::common::log_store_impl::kv_log_store::{
@@ -545,7 +544,7 @@ impl<S: StateStoreReadIter> LogStoreRowOpStream<S> {
     }
 }
 
-pub(crate) type LogStoreItemMergeStream<S: StateStoreIter + 'static> =
+pub(crate) type LogStoreItemMergeStream<S: StateStoreReadIter + 'static> =
     impl Stream<Item = LogStoreResult<(u64, KvLogStoreItem)>>;
 pub(crate) fn merge_log_store_item_stream<S: StateStoreReadIter>(
     iters: Vec<S>,