Index: src/main/java/org/apache/hadoop/hbase/regionserver/Store.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/Store.java (revision 1310074) +++ src/main/java/org/apache/hadoop/hbase/regionserver/Store.java (working copy) @@ -36,6 +36,7 @@ import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.locks.ReentrantReadWriteLock; +import java.net.URI; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -554,12 +555,17 @@ // Move the file if it's on another filesystem FileSystem srcFs = srcPath.getFileSystem(conf); - if (!srcFs.equals(fs)) { + URI srcUri = srcFs.getUri(); + URI destUri = fs.getUri(); + if (!srcUri.equals(destUri)) { + LOG.info("srcUri: " + srcUri + " destUri: " + destUri); LOG.info("File " + srcPath + " on different filesystem than " + - "destination store - moving to this filesystem."); + "destination store - moving to this filesystem. " + + "srcUri: " + srcUri + " destUri: " + destUri); Path tmpPath = getTmpPath(); FileUtil.copy(srcFs, srcPath, fs, tmpPath, false, conf); - LOG.info("Copied to temporary path on dst filesystem: " + tmpPath); + LOG.info("Copied " + srcPath + + "to temporary path on dst filesystem: " + tmpPath); srcPath = tmpPath; }