diff --git a/coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java b/coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java index cc9b553ece..0ba266cf27 100644 --- a/coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java +++ b/coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java @@ -141,9 +141,10 @@ private void updateExcludeNodes(String path) { Path hadoopPath = new Path(path); FileStatus fileStatus = hadoopFileSystem.getFileStatus(hadoopPath); if (fileStatus != null && fileStatus.isFile()) { - if (excludeLastModify.get() != fileStatus.getModificationTime()) { + long latestModificationTime = fileStatus.getModificationTime(); + if (excludeLastModify.get() != latestModificationTime) { parseExcludeNodesFile(hadoopFileSystem.open(hadoopPath)); - excludeLastModify.set(fileStatus.getModificationTime()); + excludeLastModify.set(latestModificationTime); } } else { excludeNodes = Sets.newConcurrentHashSet();