You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by ku...@apache.org on 2010/07/26 13:55:39 UTC

svn commit: r979252 - in /nutch/branches/branch-1.2: CHANGES.txt src/java/org/apache/nutch/searcher/DistributedSearchBean.java src/java/org/apache/nutch/searcher/DistributedSegmentBean.java

Author: kubes
Date: Mon Jul 26 11:55:39 2010
New Revision: 979252

URL: http://svn.apache.org/viewvc?rev=979252&view=rev
Log:
NUTCH-857 DistributedBeans should not close their RPC counterparts.  Removes closing of RPC counterparts in the DistributedSearch and DistributedSegment beans.

Modified:
    nutch/branches/branch-1.2/CHANGES.txt
    nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSearchBean.java
    nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSegmentBean.java

Modified: nutch/branches/branch-1.2/CHANGES.txt
URL: http://svn.apache.org/viewvc/nutch/branches/branch-1.2/CHANGES.txt?rev=979252&r1=979251&r2=979252&view=diff
==============================================================================
--- nutch/branches/branch-1.2/CHANGES.txt (original)
+++ nutch/branches/branch-1.2/CHANGES.txt Mon Jul 26 11:55:39 2010
@@ -2,6 +2,8 @@ Nutch Change Log
 
 Release 1.2 - Current Development
 
+* NUTCH-857 DistributedBeans should not close their RPC counterparts (kubes)
+  
 * NUTCH-855 ScoringFilter and IndexingFilter: To allow for the propagation of URL Metatags 
   and their subsequent indexing (Scott Gonyea via mattmann)
 

Modified: nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSearchBean.java
URL: http://svn.apache.org/viewvc/nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSearchBean.java?rev=979252&r1=979251&r2=979252&view=diff
==============================================================================
--- nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSearchBean.java (original)
+++ nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSearchBean.java Mon Jul 26 11:55:39 2010
@@ -283,9 +283,6 @@ public class DistributedSearchBean imple
   public void close() throws IOException {
     executor.shutdown();
     pingService.shutdown();
-    for (SearchBean bean : beans) {
-      bean.close();
-    }
   }
 
   public HitDetails getDetails(Hit hit) throws IOException {

Modified: nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSegmentBean.java
URL: http://svn.apache.org/viewvc/nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSegmentBean.java?rev=979252&r1=979251&r2=979252&view=diff
==============================================================================
--- nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSegmentBean.java (original)
+++ nutch/branches/branch-1.2/src/java/org/apache/nutch/searcher/DistributedSegmentBean.java Mon Jul 26 11:55:39 2010
@@ -166,9 +166,6 @@ public class DistributedSegmentBean impl
   public void close() throws IOException {
     executor.shutdown();
     pingService.shutdown();
-    for (SegmentBean bean : beans) {
-      bean.close();
-    }
   }
 
   public Summary getSummary(HitDetails details, Query query)