Index: src/java/org/apache/nutch/searcher/DistributedSearch.java
===================================================================
--- src/java/org/apache/nutch/searcher/DistributedSearch.java	(revision 427230)
+++ src/java/org/apache/nutch/searcher/DistributedSearch.java	(working copy)
@@ -30,6 +30,7 @@
 
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.ipc.RPC;
+import org.apache.hadoop.ipc.RemoteException;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.FileSystem;
 
@@ -277,15 +278,29 @@
       return new Hits(totalHits, (Hit[])queue.toArray(new Hit[queue.size()]));
     }
     
+    public static final long versionID = 1L;
+    
     private Protocol getRemote(Hit hit) {
-      return (Protocol)
-        RPC.getProxy(Protocol.class, defaultAddresses[hit.getIndexNo()], conf);
+      try {
+        return (Protocol)
+          RPC.getProxy(Protocol.class, versionID, defaultAddresses[hit.getIndexNo()], conf);
+      } catch (RemoteException e) {
+        // TODO Auto-generated catch block
+        e.printStackTrace();
+      } 
+      return null;
     }
 
     private Protocol getRemote(HitDetails hit) {
       InetSocketAddress address =
         (InetSocketAddress)segmentToAddress.get(hit.getValue("segment"));
-      return (Protocol)RPC.getProxy(Protocol.class, address, conf);
+      try {
+        return (Protocol)RPC.getProxy(Protocol.class, versionID, address, conf);
+      } catch (RemoteException e) {
+        // TODO Auto-generated catch block
+        e.printStackTrace();
+      }
+      return null;
     }
 
     public String getExplanation(Query query, Hit hit) throws IOException {