don't cleanup a Tap if not Hfs

cwensel · Apr 21, 2009 · f38396c · f38396c
1 parent 1ad36fe
commit f38396c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/core/cascading/tap/hadoop/Hadoop18TapUtil.java b/src/core/cascading/tap/hadoop/Hadoop18TapUtil.java
@@ -39,6 +39,7 @@
 
 package cascading.tap.hadoop;
 
+import cascading.tap.Hfs;
 import cascading.tap.Tap;
 import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
@@ -163,7 +164,9 @@ public static void commitTask( JobConf conf ) throws IOException
    */
   public static void cleanupTap( JobConf conf, Tap tap ) throws IOException
     {
-    cleanTempPath( conf, tap.getPath() );
+    // don't clean if not hfs
+    if( tap instanceof Hfs )
+      cleanTempPath( conf, tap.getPath() );
     }
 
   /**