diff --git a/internal/venice-common/src/main/java/com/linkedin/venice/blobtransfer/DaVinciBlobFinder.java b/internal/venice-common/src/main/java/com/linkedin/venice/blobtransfer/DaVinciBlobFinder.java index f16848112a..20cbc00f0c 100644 --- a/internal/venice-common/src/main/java/com/linkedin/venice/blobtransfer/DaVinciBlobFinder.java +++ b/internal/venice-common/src/main/java/com/linkedin/venice/blobtransfer/DaVinciBlobFinder.java @@ -52,6 +52,7 @@ AbstractAvroStoreClient startStoreClient(String storeName) { ClientConfig storeClientConfig = ClientConfig.cloneConfig(clientConfig).setStoreName(storeName); AbstractAvroStoreClient storeLevelClient = new AvroGenericStoreClientImpl<>(getTransportClient(storeClientConfig), false, storeClientConfig); + storeLevelClient.start(); LOGGER.info("Started store client for store: {}", storeName); return storeLevelClient; });