Repository: sqoop Updated Branches: refs/heads/sqoop2 a4e0bfa51 -> 9febdf3ae
SQOOP-1831: Sqoop2: Log filenames of detected Mapreduce files in HdfsUtils (Jarek Jarcec Cecho via Abraham Elmahrek) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/9febdf3a Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/9febdf3a Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/9febdf3a Branch: refs/heads/sqoop2 Commit: 9febdf3aed54dfd2dc48e01c2e292ad9a869ce94 Parents: a4e0bfa Author: Abraham Elmahrek <[email protected]> Authored: Thu Dec 4 00:30:13 2014 -0800 Committer: Abraham Elmahrek <[email protected]> Committed: Thu Dec 4 00:30:13 2014 -0800 ---------------------------------------------------------------------- test/src/main/java/org/apache/sqoop/test/utils/HdfsUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/9febdf3a/test/src/main/java/org/apache/sqoop/test/utils/HdfsUtils.java ---------------------------------------------------------------------- diff --git a/test/src/main/java/org/apache/sqoop/test/utils/HdfsUtils.java b/test/src/main/java/org/apache/sqoop/test/utils/HdfsUtils.java index ec650e1..5a55b8b 100644 --- a/test/src/main/java/org/apache/sqoop/test/utils/HdfsUtils.java +++ b/test/src/main/java/org/apache/sqoop/test/utils/HdfsUtils.java @@ -33,7 +33,6 @@ import java.util.LinkedList; */ public class HdfsUtils { - @SuppressWarnings("unused") private static final Logger LOG = Logger.getLogger(HdfsUtils.class); private static final char PATH_SEPARATOR = '/'; @@ -49,6 +48,7 @@ public class HdfsUtils { public static Path [] getOutputMapreduceFiles(FileSystem fs, String directory) throws FileNotFoundException, IOException { LinkedList<Path> files = new LinkedList<Path>(); for (FileStatus fileStatus : fs.listStatus(new Path(directory))) { + LOG.debug("Found mapreduce output file: " + fileStatus.getPath() + " with size " + fileStatus.getLen()); files.add(fileStatus.getPath()); } return files.toArray(new Path[files.size()]);
