Skip to content

Commit

Permalink
feat(sst meta): rollback fetch meta strategy (risingwavelabs#8917)
Browse files Browse the repository at this point in the history
  • Loading branch information
soundOfDestiny authored Mar 31, 2023
1 parent 6c99e93 commit 96d92ca
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions src/storage/src/hummock/store/version.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ use std::iter::once;
use std::sync::Arc;

use bytes::Bytes;
use futures::{stream, StreamExt};
use itertools::Itertools;
use minitrace::future::FutureExt;
use minitrace::Span;
Expand Down Expand Up @@ -655,12 +654,10 @@ impl HummockVersionReader {
.with_label_values(&[table_id_label])
.start_timer();
let mut flatten_resps = vec![None; req_count];
let mut buffered = stream::iter(flatten_reqs).buffer_unordered(10);
while let Some(result) = buffered.next().await {
let (req_index, resp) = result?;
for flatten_req in flatten_reqs {
let (req_index, resp) = flatten_req.await?;
flatten_resps[req_count - req_index - 1] = Some(resp);
}
drop(buffered);
timer.observe_duration();

let mut sst_read_options = SstableIteratorReadOptions::from(&read_options);
Expand Down

0 comments on commit 96d92ca

Please sign in to comment.