hadoop-mapreduce-commits mailing list archives

Author: sharad
Date: Thu Mar 24 08:04:53 2011
New Revision: 1084868

URL: http://svn.apache.org/viewvc?rev=1084868&view=rev
Log:
Fixed MRClientProtocol refresh

Modified:
    hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-jobclient/src/main/java/org/apache/hadoop/mapred/ClientServiceDelegate.java

Modified: hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-jobclient/src/main/java/org/apache/hadoop/mapred/ClientServiceDelegate.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-jobclient/src/main/java/org/apache/hadoop/mapred/ClientServiceDelegate.java?rev=1084868&r1=1084867&r2=1084868&view=diff
==============================================================================
--- hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-jobclient/src/main/java/org/apache/hadoop/mapred/ClientServiceDelegate.java
(original)
+++ hadoop/mapreduce/branches/MR-279/mr-client/hadoop-mapreduce-client-jobclient/src/main/java/org/apache/hadoop/mapred/ClientServiceDelegate.java
Thu Mar 24 08:04:53 2011
@@ -73,7 +73,7 @@ public class ClientServiceDelegate {
 
   private MRClientProtocol getProxy(ApplicationID appId, 
       boolean forceRefresh) throws AvroRemoteException {
-    if (currentAppId != appId || forceRefresh) {
+    if (!appId.equals(currentAppId) || forceRefresh) {
       currentAppId = appId;
       refreshProxy();
     }