svn commit: r1564210 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java

[edwardyoon]

Author: edwardyoon
Date: Tue Feb  4 05:50:39 2014
New Revision: 1564210

URL: http://svn.apache.org/r1564210
Log:
remove duplicated code.

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java

Modified: 
hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java?rev=1564210&r1=1564209&r2=1564210&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java 
(original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/PartitioningRunner.java 
Tue Feb  4 05:50:39 2014
@@ -274,8 +274,6 @@ public class PartitioningRunner extends
 
     comparisonMap.clear();
     writer.close();
-
-    deleteSlices(status);
   }
 
   @SuppressWarnings({ "rawtypes", "unchecked" })
@@ -301,16 +299,6 @@ public class PartitioningRunner extends
       reader.close();
     }
     writer.close();
-
-    deleteSlices(status);
-  }
-
-  private void deleteSlices(FileStatus[] status) throws IOException {
-    for (int i = 0; i < status.length; i++) {
-      fs.delete(status[i].getPath(), true);
-      if (fs.exists(status[i].getPath().suffix(".sorted")))
-        fs.delete(status[i].getPath().suffix(".sorted"), true);
-    }
   }
 
   @Override