Updated Branches: refs/heads/apache-blur-0.2 4f276ffa3 -> c0622345c
Removing some commented code. Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/e171c4e0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/e171c4e0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/e171c4e0 Branch: refs/heads/apache-blur-0.2 Commit: e171c4e05cbcc5cced99c0bfdc2dc048e8a6c379 Parents: 4f276ff Author: Aaron McCurry <[email protected]> Authored: Tue Dec 31 19:31:51 2013 -0500 Committer: Aaron McCurry <[email protected]> Committed: Tue Dec 31 19:31:51 2013 -0500 ---------------------------------------------------------------------- .../apache/blur/store/hdfs/HdfsDirectory.java | 37 +------------------- 1 file changed, 1 insertion(+), 36 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/e171c4e0/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java ---------------------------------------------------------------------- diff --git a/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java b/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java index 9a5020d..7ea7fe4 100644 --- a/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java +++ b/blur-store/src/main/java/org/apache/blur/store/hdfs/HdfsDirectory.java @@ -59,40 +59,6 @@ public class HdfsDirectory extends Directory implements LastModified { public static AtomicInteger fetchImpl = new AtomicInteger(3); - // static { - // Thread thread = new Thread(new Runnable() { - // @Override - // public void run() { - // while (true) { - // File file = new File("/tmp/fetch.impl"); - // if (file.exists()) { - // try { - // BufferedReader reader = new BufferedReader(new InputStreamReader(new - // FileInputStream(file))); - // String line = reader.readLine(); - // String trim = line.trim(); - // int i = Integer.parseInt(trim); - // if (i != fetchImpl.get()) { - // LOG.info("Changing fetch impl [" + i + "]"); - // fetchImpl.set(i); - // } - // reader.close(); - // } catch (Exception e) { - // LOG.error("Unknown error", e); - // } - // } - // try { - // Thread.sleep(5000); - // } catch (InterruptedException e) { - // return; - // } - // } - // } - // }); - // thread.setDaemon(true); - // thread.start(); - // } - /** * We keep the metrics separate per filesystem. */ @@ -318,7 +284,6 @@ public class HdfsDirectory extends Directory implements LastModified { @Override public void copy(Directory to, String src, String dest, IOContext context) throws IOException { - LOG.warn("DANGEROUS copy [{0}] [{1}] [{2}] [{3}] [{4}]", to, src, dest, context, _path); if (to instanceof DirectoryDecorator) { copy(((DirectoryDecorator) to).getOriginalDirectory(), src, dest, context); } else if (to instanceof HdfsDirectory) { @@ -327,7 +292,6 @@ public class HdfsDirectory extends Directory implements LastModified { } } else { slowCopy(to, src, dest, context); - } } @@ -336,6 +300,7 @@ public class HdfsDirectory extends Directory implements LastModified { } private boolean quickMove(Directory to, String src, String dest, IOContext context) throws IOException { + LOG.warn("DANGEROUS copy [{0}] [{1}] [{2}] [{3}] [{4}]", to, src, dest, context, _path); HdfsDirectory simpleTo = (HdfsDirectory) to; if (ifSameCluster(simpleTo, this)) { Path newDest = simpleTo.getPath(dest);
