hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kennethx...@apache.org
Subject svn commit: r1500000 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java
Date Fri, 05 Jul 2013 13:29:05 GMT
Author: kennethxian
Date: Fri Jul  5 13:29:04 2013
New Revision: 1500000

URL: http://svn.apache.org/r1500000
Log:
Omitted commitment for HAMA-769, DiskQueue should not clean parent directory for each iteration.

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java?rev=1500000&r1=1499999&r2=1500000&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/message/queue/DiskQueue.java Fri Jul
 5 13:29:04 2013
@@ -88,11 +88,11 @@ public final class DiskQueue<M extends W
   @Override
   public void close() {
     closeInternal(true);
-    try {
-      fs.delete(queuePath.getParent(), true);
-    } catch (IOException e) {
-      LOG.error(e);
-    }
+    // try {
+    // fs.delete(queuePath.getParent(), true);
+    // } catch (IOException e) {
+    // LOG.error(e);
+    // }
   }
 
   /**



Mime
View raw message