Skip to content

Commit

Permalink
[dvc]
Browse files Browse the repository at this point in the history
  • Loading branch information
kristyelee committed Feb 8, 2025
1 parent 418c057 commit 1f861b0
Showing 1 changed file with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@

import com.linkedin.davinci.config.VeniceConfigLoader;
import com.linkedin.davinci.kafka.consumer.KafkaStoreIngestionService;
import com.linkedin.davinci.notifier.VeniceNotifier;
import com.linkedin.davinci.stats.AggVersionedStorageEngineStats;
import com.linkedin.davinci.storage.StorageEngineRepository;
import com.linkedin.davinci.storage.StorageService;
Expand Down Expand Up @@ -236,10 +235,6 @@ public Object answer(InvocationOnMock invocation) throws Throwable {
aggVersionedStorageEngineStatsField.setAccessible(true);
aggVersionedStorageEngineStatsField.set(backend, mockAggVersionedStorageEngineStats);

VeniceNotifier ingestionListener = mock(VeniceNotifier.class);
Field ingestionListenerField = DaVinciBackend.class.getDeclaredField("ingestionListener");
ingestionListenerField.setAccessible(true);
ingestionListenerField.set(backend, ingestionListener);
KafkaStoreIngestionService storeIngestionService = mock(KafkaStoreIngestionService.class);
Field ingestionServiceField = DaVinciBackend.class.getDeclaredField("ingestionService");
ingestionServiceField.setAccessible(true);
Expand Down

0 comments on commit 1f861b0

Please sign in to comment.