From 9bf68cbd8a6ead0479957fa2430b164348ae5093 Mon Sep 17 00:00:00 2001 From: Igor Motov Date: Thu, 17 Aug 2023 13:49:18 -1000 Subject: [PATCH] Fix build after rebase --- .../src/cache_storage_controller.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/quickwit/quickwit-control-plane/src/cache_storage_controller.rs b/quickwit/quickwit-control-plane/src/cache_storage_controller.rs index ae2c7824986..a367b5cfbb5 100644 --- a/quickwit/quickwit-control-plane/src/cache_storage_controller.rs +++ b/quickwit/quickwit-control-plane/src/cache_storage_controller.rs @@ -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, }; @@ -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> = 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 {