[dvc] Config flag enabled for subscribing on disk partitions automati…

…cally. Integration Test [In Writing]
linkedin · Dec 12, 2024 · 69d619a · 69d619a
1 parent fd9fa02
commit 69d619a
Showing 1 changed file with 0 additions and 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
@@ -477,10 +477,6 @@ private synchronized void bootstrap() {
         AbstractStorageEngine storageEngine = storageService.getStorageEngine(versionTopic);
         aggVersionedStorageEngineStats.setStorageEngine(versionTopic, storageEngine);
         StoreBackend storeBackend = getStoreOrThrow(storeName);
-        ComplementSet<Integer> subscription = ComplementSet.newSet(storeBackend.getSubscription());
-        ComplementSet<Integer> unassignedPartitionSet = ComplementSet.newSet(storageEngine.getPersistedPartitionIds());
-        unassignedPartitionSet.removeAll(subscription);
-        storeBackend.unsubscribe(unassignedPartitionSet);
         storeBackend.subscribe(ComplementSet.newSet(partitions), Optional.of(version));
       });
     }