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

[sharad]

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();
     }