From 69d619a22d06531a659551417136581ae22059d5 Mon Sep 17 00:00:00 2001 From: Kristy Lee <18691669+kristyelee@users.noreply.github.com> Date: Wed, 11 Dec 2024 23:38:17 -0800 Subject: [PATCH] [dvc] Config flag enabled for subscribing on disk partitions automatically. Integration Test [In Writing] --- .../src/main/java/com/linkedin/davinci/DaVinciBackend.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/DaVinciBackend.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/DaVinciBackend.java index 24f41b3bec..27144d6f02 100644 --- a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/DaVinciBackend.java +++ b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/DaVinciBackend.java @@ -477,10 +477,6 @@ private synchronized void bootstrap() { AbstractStorageEngine storageEngine = storageService.getStorageEngine(versionTopic); aggVersionedStorageEngineStats.setStorageEngine(versionTopic, storageEngine); StoreBackend storeBackend = getStoreOrThrow(storeName); - ComplementSet subscription = ComplementSet.newSet(storeBackend.getSubscription()); - ComplementSet unassignedPartitionSet = ComplementSet.newSet(storageEngine.getPersistedPartitionIds()); - unassignedPartitionSet.removeAll(subscription); - storeBackend.unsubscribe(unassignedPartitionSet); storeBackend.subscribe(ComplementSet.newSet(partitions), Optional.of(version)); }); }