From 60e23c8e0dad4c459db6f233498ac4b589019dd8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B4=94=E5=BB=BA=E4=BC=9F?= Date: Sat, 17 Dec 2016 17:51:36 +0800 Subject: [PATCH] SnapshotFileCache will always refresh cache --- .../hbase/master/snapshot/SnapshotFileCache.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java index f80d962..a69b32a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java @@ -212,7 +212,7 @@ public class SnapshotFileCache implements Stoppable { try { FileStatus dirStatus = fs.getFileStatus(snapshotDir); lastTimestamp = dirStatus.getModificationTime(); - hasChanges |= (lastTimestamp >= lastModifiedTime); + hasChanges |= (lastTimestamp > lastModifiedTime); } catch (FileNotFoundException e) { if (this.cache.size() > 0) { LOG.error("Snapshot directory: " + snapshotDir + " doesn't exist"); @@ -226,14 +226,14 @@ public class SnapshotFileCache implements Stoppable { Path snapshotTmpDir = new Path(snapshotDir, SnapshotDescriptionUtils.SNAPSHOT_TMP_DIR_NAME); FileStatus tempDirStatus = fs.getFileStatus(snapshotTmpDir); lastTimestamp = Math.min(lastTimestamp, tempDirStatus.getModificationTime()); - hasChanges |= (lastTimestamp >= lastModifiedTime); + hasChanges |= (lastTimestamp > lastModifiedTime); if (!hasChanges) { FileStatus[] tmpSnapshots = FSUtils.listStatus(fs, snapshotDir); if (tmpSnapshots != null) { for (FileStatus dirStatus: tmpSnapshots) { lastTimestamp = Math.min(lastTimestamp, dirStatus.getModificationTime()); } - hasChanges |= (lastTimestamp >= lastModifiedTime); + hasChanges |= (lastTimestamp > lastModifiedTime); } } } catch (FileNotFoundException e) { -- 1.7.9.5