fix: Fixes the AllHostsLocatorTest

confluentinc · Jan 26, 2022 · 228b353 · 228b353
1 parent a5bb05d
commit 228b353
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ne/src/test/java/io/confluent/ksql/physical/scalablepush/locator/AllHostsLocatorTest.java b/...ne/src/test/java/io/confluent/ksql/physical/scalablepush/locator/AllHostsLocatorTest.java
@@ -1,5 +1,6 @@
 package io.confluent.ksql.physical.scalablepush.locator;
 
+import static org.apache.kafka.streams.state.internals.StreamsMetadataImpl.NOT_AVAILABLE;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.is;
 import static org.mockito.Mockito.when;
@@ -43,7 +44,7 @@ public void shouldLocate() throws MalformedURLException {
     when(metadata1.getAllMetadata())
         .thenReturn(ImmutableList.of(streamsMetadata1, streamsMetadata2));
     when(metadata2.getAllMetadata())
-        .thenReturn(Collections.emptyList());
+        .thenReturn(ImmutableList.of(streamsMetadata3));
     when(streamsMetadata1.hostInfo())
         .thenReturn(new HostInfo("abc", 101), new HostInfo("localhost", 8088));
     when(streamsMetadata2.hostInfo()).thenReturn(new HostInfo("localhost", 8088));