svn commit: r1488366 - in /nutch/branches/2.x: CHANGES.txt src/java/org/apache/nutch/host/HostDb.java

[lewismc]

Author: lewismc
Date: Fri May 31 19:44:10 2013
New Revision: 1488366

URL: http://svn.apache.org/r1488366
Log:
NUTCH-1576 Need to keep hotStore.flush() exception catching

Modified:
    nutch/branches/2.x/CHANGES.txt
    nutch/branches/2.x/src/java/org/apache/nutch/host/HostDb.java

Modified: nutch/branches/2.x/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/nutch/branches/2.x/CHANGES.txt?rev=1488366&r1=1488365&r2=1488366&view=diff
==============================================================================
--- nutch/branches/2.x/CHANGES.txt (original)
+++ nutch/branches/2.x/CHANGES.txt Fri May 31 19:44:10 2013
@@ -2,6 +2,8 @@ Nutch Change Log
 
 Release 2.2 - Current Development
 
+* NUTCH-1576 Need to keep hotStore.flush() exception catching (James Sullivan 
via lewismc)
+
 * NUTCH-1577 Add target for creating eclipse project (tejasp via lewismc)
 
 * NUTCH-1545 capture batchId and remove references to segments in 2.x crawl 
script. (Feng)

Modified: nutch/branches/2.x/src/java/org/apache/nutch/host/HostDb.java
URL: 
http://svn.apache.org/viewvc/nutch/branches/2.x/src/java/org/apache/nutch/host/HostDb.java?rev=1488366&r1=1488365&r2=1488366&view=diff
==============================================================================
--- nutch/branches/2.x/src/java/org/apache/nutch/host/HostDb.java (original)
+++ nutch/branches/2.x/src/java/org/apache/nutch/host/HostDb.java Fri May 31 
19:44:10 2013
@@ -87,7 +87,11 @@ public class HostDb implements Closeable
             CacheHost removeFromCacheHost = notification.getValue();
             if (removeFromCacheHost != NULL_HOST) {
               if (removeFromCacheHost.timestamp < lastFlush.get()) {
-                hostStore.flush();
+                try {
+                  hostStore.flush();
+                } catch (Exception e) {
+                  throw new RuntimeException(e);
+                }
                 lastFlush.set(System.currentTimeMillis());
               }
             }