add test case

linkedin · Dec 16, 2024 · 78e2724 · 78e2724
1 parent bb79435
commit 78e2724
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...i-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java b/...i-client/src/test/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerImplTest.java
@@ -229,6 +229,11 @@ public void testAfterImageConsumerSeek() throws ExecutionException, InterruptedE
 
     Set<Integer> partitionSet = new HashSet<>();
     partitionSet.add(0);
+
+    // try and do it with an empty set, this should complete immediately
+    veniceChangelogConsumer.seekToEndOfPush(Collections.emptySet()).get();
+    Mockito.verifyNoInteractions(mockInternalSeekConsumer);
+
     veniceChangelogConsumer.seekToEndOfPush(partitionSet).get();
 
     Mockito.verify(mockInternalSeekConsumer).subscribe(partitionSet);