You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ab...@apache.org on 2014/12/04 09:30:42 UTC
sqoop git commit: SQOOP-1831: Sqoop2: Log filenames of detected
Mapreduce files in HdfsUtils
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 <ab...@elmahrek.com>
Authored: Thu Dec 4 00:30:13 2014 -0800
Committer: Abraham Elmahrek <ab...@elmahrek.com>
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()]);