HBASE-23045 currentPath may be stitched in a loop in replication source code. (#1006)
Co-authored-by: Viraj Jasani <vjasani@apache.org> Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
parent
dfe636017d
commit
66f1658167
|
@ -938,8 +938,9 @@ public class ReplicationSource extends Thread implements ReplicationSourceInterf
|
||||||
Path p = rs.getPath();
|
Path p = rs.getPath();
|
||||||
FileStatus[] logs = fs.listStatus(p);
|
FileStatus[] logs = fs.listStatus(p);
|
||||||
for (FileStatus log : logs) {
|
for (FileStatus log : logs) {
|
||||||
|
String logName = log.getPath().getName();
|
||||||
|
if (logName.equals(path.getName())) {
|
||||||
p = new Path(p, log.getPath().getName());
|
p = new Path(p, log.getPath().getName());
|
||||||
if (p.getName().equals(path.getName())) {
|
|
||||||
LOG.info("Log " + p.getName() + " found at " + p);
|
LOG.info("Log " + p.getName() + " found at " + p);
|
||||||
return p;
|
return p;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue