diff --git a/coordinator/src/test/java/org/apache/uniffle/coordinator/SimpleClusterManagerTest.java b/coordinator/src/test/java/org/apache/uniffle/coordinator/SimpleClusterManagerTest.java index db72f633ed..c38e180813 100644 --- a/coordinator/src/test/java/org/apache/uniffle/coordinator/SimpleClusterManagerTest.java +++ b/coordinator/src/test/java/org/apache/uniffle/coordinator/SimpleClusterManagerTest.java @@ -451,6 +451,8 @@ public void updateExcludeNodesTest() throws Exception { remainNodes, availableNodes.stream().map(ServerNode::getId).collect(Collectors.toSet())); final Set nodes2 = Sets.newHashSet("node3-1999", "node4-1999"); + // Make sure last modification time change + Thread.sleep(1000); writeExcludeHosts(excludeNodesPath, nodes2); await().atMost(3, TimeUnit.SECONDS).until(() -> scm.getExcludedNodes().equals(nodes2)); assertEquals(nodes2, scm.getExcludedNodes());