Added info log message when writing "direct" to a filesystem, bypassi…

…ng the temporary folder removing the need to rename the output file to its target location.
johnynek · Jul 8, 2011 · 114494c · 114494c
1 parent 0c0509c
commit 114494c
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/CHANGES.txt b/CHANGES.txt
@@ -2,6 +2,9 @@ Cascading Change Log
 
 1.2.4 [unreleased]
 
+  Added info log message when writing "direct" to a filesystem, bypassing the temporary folder removing the need to
+  rename the output file to its target location.
+
   Fixed bug where if all paths that match a glob pattern are empty, an exception is not thrown causing Hadoop to throw
   a java.lang.ArrayIndexOutOfBoundsException.
 

diff --git a/src/core/cascading/tap/hadoop/Hadoop18TapUtil.java b/src/core/cascading/tap/hadoop/Hadoop18TapUtil.java
@@ -341,7 +341,12 @@ private static boolean writeDirectlyToWorkingPath( JobConf conf, Path path )
     if( fs == null )
       return false;
 
-    return conf.getBoolean( "mapred.output.direct." + fs.getClass().getSimpleName(), false );
+    boolean result = conf.getBoolean( "mapred.output.direct." + fs.getClass().getSimpleName(), false );
+
+    if( result )
+      LOG.info( "output direct is enabled for this fs: " + fs.getName() );
+
+    return result;
     }
 
   }