fix

linkedin · Feb 27, 2025 · e084dad · e084dad
1 parent 6b04f54
commit e084dad
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ommon/src/integrationTest/java/com/linkedin/venice/endToEnd/TestDumpIngestionContext.java b/...ommon/src/integrationTest/java/com/linkedin/venice/endToEnd/TestDumpIngestionContext.java
@@ -131,7 +131,7 @@ public void testDumpHostHeartbeatLag() {
       LOGGER.info("Heartbeat Info with topic filtering:\n" + heartbeatInfoMap);
       Assert.assertEquals(heartbeatInfoMap.keySet().stream().filter(x -> x.endsWith("dc-0")).count(), 3);
       Assert.assertEquals(
-          heartbeatInfoMap.keySet().stream().filter(x -> x.endsWith("dc-1")).count() * 2,
+          heartbeatInfoMap.keySet().stream().filter(x -> x.contains("dc-1")).count() * 2,
           heartbeatInfoMap.values().stream().filter(x -> x.getLeaderState().equals("LEADER")).count());
 
       heartbeatInfoMap = serverWrapper.getVeniceServer()