From 2fa074ae36605c5df766ac7e0b606d02cdfc610c Mon Sep 17 00:00:00 2001 From: "guo.kangkang" Date: Wed, 18 Sep 2019 17:38:47 +0800 Subject: [PATCH] fix ReplicationSource bug --- .../hadoop/hbase/replication/regionserver/ReplicationSource.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java index ff79976f6d..b13f838a2e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java @@ -801,9 +801,9 @@ public class ReplicationSource extends Thread Path p = rs.getPath(); FileStatus[] logs = fs.listStatus(p); for (FileStatus log : logs) { - p = new Path(p, log.getPath().getName()); - if (p.getName().equals(currentPath.getName())) { - currentPath = p; + String logName = log.getPath().getName(); + if (logName.equals(currentPath.getName())) { + currentPath = new Path(p, logName); LOG.info("Log " + currentPath.getName() + " found at " + currentPath); // Open the log at the new location this.openReader(sleepMultiplier); -- 2.15.1 (Apple Git-101)