From a1b2dced9a62207563a14a7c4bcb94d0bd11f78d Mon Sep 17 00:00:00 2001 From: jingy-li Date: Fri, 7 Feb 2025 13:34:55 -0800 Subject: [PATCH] start store level client --- .../java/com/linkedin/venice/blobtransfer/DaVinciBlobFinder.java | 1 + 1 file changed, 1 insertion(+) 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 f16848112ae..20cbc00f0c2 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; });