From e611f03017e6e96c64665ab338d2708a8ebce914 Mon Sep 17 00:00:00 2001 From: baoloongmao Date: Wed, 8 Jan 2025 09:01:59 +0800 Subject: [PATCH] Fix flaky test SimpleClusterManagerTest#updateExcludeNodesTest --- .../apache/uniffle/coordinator/SimpleClusterManagerTest.java | 2 ++ 1 file changed, 2 insertions(+) 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());