Skip to content

Commit

Permalink
fix check warn
Browse files Browse the repository at this point in the history
Signed-off-by: Little-Wallace <[email protected]>
  • Loading branch information
Little-Wallace committed Jun 19, 2023
1 parent 19a514a commit b82ee1c
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 6 deletions.
2 changes: 1 addition & 1 deletion src/storage/benches/bench_compactor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,7 @@ async fn scan_all_table(info: &SstableInfo, sstable_store: SstableStoreRef) {
let default_read_options = Arc::new(SstableIteratorReadOptions::default());
// warm up to make them all in memory. I do not use CachePolicy::Fill because it will fetch
// block from meta.
let mut iter = SstableIterator::new(table, sstable_store.clone(), default_read_options);
let mut iter = SstableIterator::new(table, sstable_store.clone(), default_read_options, false);
iter.rewind().await.unwrap();
while iter.is_valid() {
iter.next().await.unwrap();
Expand Down
8 changes: 3 additions & 5 deletions src/storage/src/hummock/event_handler/cache_refill_policy.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,14 +12,12 @@
// See the License for the specific language governing permissions and
// limitations under the License.

use std::cmp::{Ordering, Reverse};
use std::collections::binary_heap::PeekMut;
use std::collections::{BinaryHeap, HashMap};
use std::cmp::Ordering;
use std::sync::Arc;
use std::time::Duration;

use futures::future::try_join_all;
use risingwave_hummock_sdk::{HummockSstableObjectId, KeyComparator};
use risingwave_hummock_sdk::KeyComparator;
use risingwave_pb::hummock::{group_delta, HummockVersionDelta, SstableInfo};
use tokio::task::JoinHandle;
use tracing::{info, warn};
Expand Down Expand Up @@ -130,8 +128,8 @@ pub struct SstableBlocksInfo {
impl SstableBlocksInfo {
pub fn new(sstable: TableHolder) -> Self {
Self {
sstable,
blocks_in_cache: vec![false; sstable.value().meta.block_metas.len()],
sstable,
}
}
}
Expand Down
1 change: 1 addition & 0 deletions src/storage/src/hummock/sstable_store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -952,6 +952,7 @@ mod tests {
holder,
sstable_store,
Arc::new(SstableIteratorReadOptions::default()),
false,
);
iter.rewind().await.unwrap();
for i in x_range {
Expand Down

0 comments on commit b82ee1c

Please sign in to comment.