Skip to content

Commit

Permalink
Fix build after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
imotov committed Aug 17, 2023
1 parent 2462172 commit 9bf68cb
Showing 1 changed file with 6 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ use quickwit_cache_storage::CacheStorageService;
use quickwit_cluster::ClusterChange;
use quickwit_common::rendezvous_hasher::sort_by_rendez_vous_hash;
use quickwit_common::uri::{Protocol, Uri};
use quickwit_metastore::{IndexMetadata, ListSplitsQuery, Metastore};
use quickwit_metastore::{IndexMetadata, ListIndexesQuery, ListSplitsQuery, Metastore};
use quickwit_proto::cache_storage::{
CacheStorageServiceClient, NotifySplitsChangeRequest, SplitsChangeNotification,
};
Expand Down Expand Up @@ -107,7 +107,11 @@ impl CacheStorageController {
let mut updated_nodes = HashSet::new();
let available_nodes = self.pool.available_nodes().await;
let mut node_to_split_map: HashMap<String, Vec<(String, IndexUid, Uri)>> = HashMap::new();
for index_metadata in self.metastore.list_indexes_metadatas().await? {
for index_metadata in self
.metastore
.list_indexes_metadatas(ListIndexesQuery::All)
.await?
{
let index_uid = index_metadata.index_uid.clone();
let storage_uri = index_metadata.index_uri();
if storage_uri.protocol() != Protocol::Cache {
Expand Down

0 comments on commit 9bf68cb

Please sign in to comment.