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);
+ // }
}
/**
